From 18c61cead3e7c23b45259dd0555c9c799082798b Mon Sep 17 00:00:00 2001 From: zhanggougou <15651908511@163.com> Date: Fri, 25 Apr 2025 16:42:51 +0800 Subject: [PATCH 1/3] =?UTF-8?q?[fire-1224]=20=E5=B0=8F=E7=89=88=E6=9C=AC?= =?UTF-8?q?=E5=8D=87=E7=BA=A7=EF=BC=8C=E9=85=8D=E7=BD=AE=E4=B8=AD=E5=BF=83?= =?UTF-8?q?=E6=8E=A5=E5=8F=A3=E5=8D=87=E7=BA=A7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- fire-bundle/fire-bundle-flink/pom.xml | 2 +- fire-bundle/fire-bundle-spark/pom.xml | 2 +- fire-bundle/pom.xml | 2 +- fire-common/pom.xml | 2 +- .../bean/config/ConfigurationParam.java | 29 +++++++------------ .../util/ConfigurationCenterManager.scala | 4 +-- .../base-connectors/fire-hbase/pom.xml | 2 +- .../base-connectors/fire-jdbc/pom.xml | 2 +- fire-connectors/base-connectors/pom.xml | 2 +- .../flink-connectors/flink-clickhouse/pom.xml | 2 +- .../flink-connectors/flink-format/pom.xml | 2 +- .../flink-connectors/flink-paimon/pom.xml | 2 +- .../flink-connectors/flink-rocketmq/pom.xml | 2 +- fire-connectors/flink-connectors/pom.xml | 2 +- fire-connectors/pom.xml | 2 +- fire-connectors/spark-connectors/pom.xml | 2 +- .../spark-connectors/spark-hbase/pom.xml | 2 +- .../spark-connectors/spark-hudi/pom.xml | 2 +- .../spark-connectors/spark-rocketmq/pom.xml | 2 +- fire-core/pom.xml | 2 +- fire-engines/fire-flink/pom.xml | 2 +- fire-engines/fire-spark/pom.xml | 2 +- fire-engines/pom.xml | 2 +- fire-enhance/apache-arthas/pom.xml | 4 +-- fire-enhance/apache-flink/pom.xml | 4 +-- fire-enhance/apache-spark/pom.xml | 4 +-- fire-enhance/pom.xml | 2 +- fire-examples/flink-examples/pom.xml | 2 +- fire-examples/pom.xml | 2 +- fire-examples/spark-examples/pom.xml | 2 +- fire-shell/flink-shell/pom.xml | 2 +- fire-shell/pom.xml | 2 +- fire-shell/spark-shell/pom.xml | 2 +- pom.xml | 2 +- 34 files changed, 47 insertions(+), 56 deletions(-) diff --git a/fire-bundle/fire-bundle-flink/pom.xml b/fire-bundle/fire-bundle-flink/pom.xml index 12da3d31..db9157da 100644 --- a/fire-bundle/fire-bundle-flink/pom.xml +++ b/fire-bundle/fire-bundle-flink/pom.xml @@ -8,7 +8,7 @@ com.zto.fire fire-bundle - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT ../pom.xml diff --git a/fire-bundle/fire-bundle-spark/pom.xml b/fire-bundle/fire-bundle-spark/pom.xml index 7e9b5d6a..71300ae4 100644 --- a/fire-bundle/fire-bundle-spark/pom.xml +++ b/fire-bundle/fire-bundle-spark/pom.xml @@ -8,7 +8,7 @@ com.zto.fire fire-bundle - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT ../pom.xml diff --git a/fire-bundle/pom.xml b/fire-bundle/pom.xml index 0eaca317..0aa88610 100644 --- a/fire-bundle/pom.xml +++ b/fire-bundle/pom.xml @@ -15,7 +15,7 @@ com.zto.fire fire-parent - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT ../pom.xml diff --git a/fire-common/pom.xml b/fire-common/pom.xml index 57e71d41..638f0685 100644 --- a/fire-common/pom.xml +++ b/fire-common/pom.xml @@ -26,7 +26,7 @@ com.zto.fire fire-parent - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT ../pom.xml diff --git a/fire-common/src/main/java/com/zto/fire/common/bean/config/ConfigurationParam.java b/fire-common/src/main/java/com/zto/fire/common/bean/config/ConfigurationParam.java index 046db3dd..5f94493f 100644 --- a/fire-common/src/main/java/com/zto/fire/common/bean/config/ConfigurationParam.java +++ b/fire-common/src/main/java/com/zto/fire/common/bean/config/ConfigurationParam.java @@ -18,6 +18,8 @@ package com.zto.fire.common.bean.config; import com.zto.fire.common.enu.ConfigureLevel; +import lombok.Getter; +import lombok.Setter; import java.util.Map; @@ -29,24 +31,13 @@ import java.util.Map; * @author ChengLong 2021-8-23 15:26:39 * @since 2.2.0 */ +@Getter +@Setter public class ConfigurationParam { - private Integer code; - private Map> content; - - public Integer getCode() { - return code; - } - - public void setCode(Integer code) { - this.code = code; - } - - public Map> getContent() { - return content; - } - - public void setContent(Map> content) { - this.content = content; - } - + private boolean status; + private String statusCode; + private String message; + private Map> result; + private String solution; + private String exception; } \ No newline at end of file diff --git a/fire-common/src/main/scala/com/zto/fire/common/util/ConfigurationCenterManager.scala b/fire-common/src/main/scala/com/zto/fire/common/util/ConfigurationCenterManager.scala index 47ced129..21e13684 100644 --- a/fire-common/src/main/scala/com/zto/fire/common/util/ConfigurationCenterManager.scala +++ b/fire-common/src/main/scala/com/zto/fire/common/util/ConfigurationCenterManager.scala @@ -101,8 +101,8 @@ private[fire] object ConfigurationCenterManager extends Serializable with Loggin FireUtils.exitError } else { val param = JSONUtils.parseObject[ConfigurationParam](json) - if (noEmpty(param, param.getCode, param.getContent) && param.getCode == 200) { - this.configCenterProperties.putAll(param.getContent) + if (param.isStatus && noEmpty(param, param.getResult) ) { + this.configCenterProperties.putAll(param.getResult) logInfo("配置中心参数已生效") } } diff --git a/fire-connectors/base-connectors/fire-hbase/pom.xml b/fire-connectors/base-connectors/fire-hbase/pom.xml index 4a13d52b..b2f5d39f 100644 --- a/fire-connectors/base-connectors/fire-hbase/pom.xml +++ b/fire-connectors/base-connectors/fire-hbase/pom.xml @@ -26,7 +26,7 @@ com.zto.fire fire-connectors-common - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT ../pom.xml diff --git a/fire-connectors/base-connectors/fire-jdbc/pom.xml b/fire-connectors/base-connectors/fire-jdbc/pom.xml index 1f23b147..e639d43b 100644 --- a/fire-connectors/base-connectors/fire-jdbc/pom.xml +++ b/fire-connectors/base-connectors/fire-jdbc/pom.xml @@ -26,7 +26,7 @@ com.zto.fire fire-connectors-common - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT ../pom.xml diff --git a/fire-connectors/base-connectors/pom.xml b/fire-connectors/base-connectors/pom.xml index 6b5a6b8d..2af2b75e 100644 --- a/fire-connectors/base-connectors/pom.xml +++ b/fire-connectors/base-connectors/pom.xml @@ -26,7 +26,7 @@ com.zto.fire fire-connectors - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT ../pom.xml diff --git a/fire-connectors/flink-connectors/flink-clickhouse/pom.xml b/fire-connectors/flink-connectors/flink-clickhouse/pom.xml index 2723621f..9da552ff 100644 --- a/fire-connectors/flink-connectors/flink-clickhouse/pom.xml +++ b/fire-connectors/flink-connectors/flink-clickhouse/pom.xml @@ -26,7 +26,7 @@ fire-flink-connectors com.zto.fire - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT diff --git a/fire-connectors/flink-connectors/flink-format/pom.xml b/fire-connectors/flink-connectors/flink-format/pom.xml index dcde4e3a..62185711 100644 --- a/fire-connectors/flink-connectors/flink-format/pom.xml +++ b/fire-connectors/flink-connectors/flink-format/pom.xml @@ -8,7 +8,7 @@ fire-flink-connectors com.zto.fire - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT ../pom.xml diff --git a/fire-connectors/flink-connectors/flink-paimon/pom.xml b/fire-connectors/flink-connectors/flink-paimon/pom.xml index 80b9eed4..9ca3c722 100644 --- a/fire-connectors/flink-connectors/flink-paimon/pom.xml +++ b/fire-connectors/flink-connectors/flink-paimon/pom.xml @@ -10,7 +10,7 @@ fire-flink-connectors com.zto.fire - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT ../pom.xml diff --git a/fire-connectors/flink-connectors/flink-rocketmq/pom.xml b/fire-connectors/flink-connectors/flink-rocketmq/pom.xml index 70a40060..f5461203 100644 --- a/fire-connectors/flink-connectors/flink-rocketmq/pom.xml +++ b/fire-connectors/flink-connectors/flink-rocketmq/pom.xml @@ -25,7 +25,7 @@ com.zto.fire fire-flink-connectors - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT ../pom.xml diff --git a/fire-connectors/flink-connectors/pom.xml b/fire-connectors/flink-connectors/pom.xml index fc590250..ae6da1aa 100644 --- a/fire-connectors/flink-connectors/pom.xml +++ b/fire-connectors/flink-connectors/pom.xml @@ -32,7 +32,7 @@ fire-connectors com.zto.fire - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT ../pom.xml diff --git a/fire-connectors/pom.xml b/fire-connectors/pom.xml index dd564fe2..71ed9443 100644 --- a/fire-connectors/pom.xml +++ b/fire-connectors/pom.xml @@ -26,7 +26,7 @@ com.zto.fire fire-parent - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT ../pom.xml diff --git a/fire-connectors/spark-connectors/pom.xml b/fire-connectors/spark-connectors/pom.xml index c0a56f1e..5fd4392d 100644 --- a/fire-connectors/spark-connectors/pom.xml +++ b/fire-connectors/spark-connectors/pom.xml @@ -31,7 +31,7 @@ fire-connectors com.zto.fire - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT ../pom.xml diff --git a/fire-connectors/spark-connectors/spark-hbase/pom.xml b/fire-connectors/spark-connectors/spark-hbase/pom.xml index 13bb4000..536e067f 100644 --- a/fire-connectors/spark-connectors/spark-hbase/pom.xml +++ b/fire-connectors/spark-connectors/spark-hbase/pom.xml @@ -26,7 +26,7 @@ fire-spark-connectors com.zto.fire - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT diff --git a/fire-connectors/spark-connectors/spark-hudi/pom.xml b/fire-connectors/spark-connectors/spark-hudi/pom.xml index 87ff0e35..d13f5e34 100644 --- a/fire-connectors/spark-connectors/spark-hudi/pom.xml +++ b/fire-connectors/spark-connectors/spark-hudi/pom.xml @@ -27,7 +27,7 @@ com.zto.fire fire-spark-connectors - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT ../pom.xml diff --git a/fire-connectors/spark-connectors/spark-rocketmq/pom.xml b/fire-connectors/spark-connectors/spark-rocketmq/pom.xml index 71794a2f..a24fd313 100644 --- a/fire-connectors/spark-connectors/spark-rocketmq/pom.xml +++ b/fire-connectors/spark-connectors/spark-rocketmq/pom.xml @@ -26,7 +26,7 @@ com.zto.fire fire-spark-connectors - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT ../pom.xml diff --git a/fire-core/pom.xml b/fire-core/pom.xml index 2bce08eb..005b23c2 100644 --- a/fire-core/pom.xml +++ b/fire-core/pom.xml @@ -26,7 +26,7 @@ com.zto.fire fire-parent - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT ../pom.xml diff --git a/fire-engines/fire-flink/pom.xml b/fire-engines/fire-flink/pom.xml index 27272e50..8ad2003e 100644 --- a/fire-engines/fire-flink/pom.xml +++ b/fire-engines/fire-flink/pom.xml @@ -26,7 +26,7 @@ com.zto.fire fire-engines - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT ../pom.xml diff --git a/fire-engines/fire-spark/pom.xml b/fire-engines/fire-spark/pom.xml index dff0abba..42e4724c 100644 --- a/fire-engines/fire-spark/pom.xml +++ b/fire-engines/fire-spark/pom.xml @@ -26,7 +26,7 @@ com.zto.fire fire-engines - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT ../pom.xml diff --git a/fire-engines/pom.xml b/fire-engines/pom.xml index 8891ea48..1b47fbbc 100644 --- a/fire-engines/pom.xml +++ b/fire-engines/pom.xml @@ -26,7 +26,7 @@ com.zto.fire fire-parent - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT ../pom.xml diff --git a/fire-enhance/apache-arthas/pom.xml b/fire-enhance/apache-arthas/pom.xml index 0cd2eb03..000d1563 100644 --- a/fire-enhance/apache-arthas/pom.xml +++ b/fire-enhance/apache-arthas/pom.xml @@ -19,14 +19,14 @@ 4.0.0 fire-enhance-arthas_${scala.binary.version} - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT jar Fire : Enhance : Arthas com.zto.fire fire-enhance - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT ../pom.xml diff --git a/fire-enhance/apache-flink/pom.xml b/fire-enhance/apache-flink/pom.xml index c0b1b4af..449ea271 100644 --- a/fire-enhance/apache-flink/pom.xml +++ b/fire-enhance/apache-flink/pom.xml @@ -19,14 +19,14 @@ 4.0.0 fire-enhance-flink_${flink.reference} - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT jar Fire : Enhance : Flink com.zto.fire fire-enhance - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT ../pom.xml diff --git a/fire-enhance/apache-spark/pom.xml b/fire-enhance/apache-spark/pom.xml index ddb4676a..9d6409a7 100644 --- a/fire-enhance/apache-spark/pom.xml +++ b/fire-enhance/apache-spark/pom.xml @@ -19,14 +19,14 @@ 4.0.0 fire-enhance-spark_${spark.reference} - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT jar Fire : Enhance : Spark com.zto.fire fire-enhance - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT ../pom.xml diff --git a/fire-enhance/pom.xml b/fire-enhance/pom.xml index b5ab7fa1..bf53754d 100644 --- a/fire-enhance/pom.xml +++ b/fire-enhance/pom.xml @@ -25,7 +25,7 @@ com.zto.fire fire-parent - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT ../pom.xml diff --git a/fire-examples/flink-examples/pom.xml b/fire-examples/flink-examples/pom.xml index 513d2621..8cc6bfa8 100644 --- a/fire-examples/flink-examples/pom.xml +++ b/fire-examples/flink-examples/pom.xml @@ -26,7 +26,7 @@ com.zto.fire fire-examples - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT ../pom.xml diff --git a/fire-examples/pom.xml b/fire-examples/pom.xml index 48bb45bf..efa7ca52 100644 --- a/fire-examples/pom.xml +++ b/fire-examples/pom.xml @@ -31,7 +31,7 @@ com.zto.fire fire-parent - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT ../pom.xml diff --git a/fire-examples/spark-examples/pom.xml b/fire-examples/spark-examples/pom.xml index bb970583..90e7cf8c 100644 --- a/fire-examples/spark-examples/pom.xml +++ b/fire-examples/spark-examples/pom.xml @@ -26,7 +26,7 @@ com.zto.fire fire-examples - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT ../pom.xml diff --git a/fire-shell/flink-shell/pom.xml b/fire-shell/flink-shell/pom.xml index c4123880..ffdf6261 100644 --- a/fire-shell/flink-shell/pom.xml +++ b/fire-shell/flink-shell/pom.xml @@ -7,7 +7,7 @@ fire-shell com.zto.fire - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT diff --git a/fire-shell/pom.xml b/fire-shell/pom.xml index ccd67178..bcb2250d 100644 --- a/fire-shell/pom.xml +++ b/fire-shell/pom.xml @@ -15,7 +15,7 @@ fire-parent com.zto.fire - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT diff --git a/fire-shell/spark-shell/pom.xml b/fire-shell/spark-shell/pom.xml index 9eaef0e8..31dd184e 100644 --- a/fire-shell/spark-shell/pom.xml +++ b/fire-shell/spark-shell/pom.xml @@ -9,7 +9,7 @@ fire-shell com.zto.fire - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT diff --git a/pom.xml b/pom.xml index 408bee7a..03a35cbf 100644 --- a/pom.xml +++ b/pom.xml @@ -22,7 +22,7 @@ com.zto.fire fire-parent pom - 2.5.3-SNAPSHOT + 2.5.4-SNAPSHOT Fire : Fire framework is a development framework for real-time computing task development . The framework provides a simple and easy to use API that can significantly reduce the development threshold of Spark and Flink and improve development efficiency. https://github.com/fire-framework/fire -- Gitee From 8f719ede17537357a4d67bcb145e7e9b68674284 Mon Sep 17 00:00:00 2001 From: zhanggougou <15651908511@163.com> Date: Fri, 9 May 2025 13:49:55 +0800 Subject: [PATCH 2/3] =?UTF-8?q?[fire-1224]=20=E5=B0=8F=E7=89=88=E6=9C=AC?= =?UTF-8?q?=E5=8D=87=E7=BA=A7=EF=BC=8C=E9=85=8D=E7=BD=AE=E4=B8=AD=E5=BF=83?= =?UTF-8?q?=E6=8E=A5=E5=8F=A3=E5=8D=87=E7=BA=A7=E5=8F=8Acluster-env?= =?UTF-8?q?=E5=8D=87=E7=BA=A7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../bean/config/ConfigurationParam.java | 50 ++++++++++++++++++- .../util/ConfigurationCenterManager.scala | 2 +- fire-examples/pom.xml | 2 +- pom.xml | 2 +- 4 files changed, 51 insertions(+), 5 deletions(-) diff --git a/fire-common/src/main/java/com/zto/fire/common/bean/config/ConfigurationParam.java b/fire-common/src/main/java/com/zto/fire/common/bean/config/ConfigurationParam.java index 5f94493f..94c1a7bd 100644 --- a/fire-common/src/main/java/com/zto/fire/common/bean/config/ConfigurationParam.java +++ b/fire-common/src/main/java/com/zto/fire/common/bean/config/ConfigurationParam.java @@ -31,8 +31,6 @@ import java.util.Map; * @author ChengLong 2021-8-23 15:26:39 * @since 2.2.0 */ -@Getter -@Setter public class ConfigurationParam { private boolean status; private String statusCode; @@ -40,4 +38,52 @@ public class ConfigurationParam { private Map> result; private String solution; private String exception; + + public boolean isStatus() { + return status; + } + + public void setStatus(boolean status) { + this.status = status; + } + + public String getStatusCode() { + return statusCode; + } + + public void setStatusCode(String statusCode) { + this.statusCode = statusCode; + } + + public String getMessage() { + return message; + } + + public void setMessage(String message) { + this.message = message; + } + + public Map> getResult() { + return result; + } + + public void setResult(Map> result) { + this.result = result; + } + + public String getSolution() { + return solution; + } + + public void setSolution(String solution) { + this.solution = solution; + } + + public String getException() { + return exception; + } + + public void setException(String exception) { + this.exception = exception; + } } \ No newline at end of file diff --git a/fire-common/src/main/scala/com/zto/fire/common/util/ConfigurationCenterManager.scala b/fire-common/src/main/scala/com/zto/fire/common/util/ConfigurationCenterManager.scala index 21e13684..c12ecd86 100644 --- a/fire-common/src/main/scala/com/zto/fire/common/util/ConfigurationCenterManager.scala +++ b/fire-common/src/main/scala/com/zto/fire/common/util/ConfigurationCenterManager.scala @@ -44,7 +44,7 @@ private[fire] object ConfigurationCenterManager extends Serializable with Loggin val rest = FireFrameworkConf.fireRestUrl if (StringUtils.isBlank(rest)) logWarning("Fire Rest Server 地址为空，将无法完成注册") s""" - |{ "url": "$rest", "fireVersion": "${FireFrameworkConf.fireVersion}", "engine": "${PropUtils.engine}", "taskId": "${getFireAppId}"} + |{ "url": "$rest", "fireVersion": "${FireFrameworkConf.fireVersion}", "taskId": "${getFireAppId}"} """.stripMargin } diff --git a/fire-examples/pom.xml b/fire-examples/pom.xml index efa7ca52..d4e3a382 100644 --- a/fire-examples/pom.xml +++ b/fire-examples/pom.xml @@ -47,7 +47,7 @@ com.zto.bigdata cluster-env - 1.0.4-SNAPSHOT + 1.0.5-SNAPSHOT diff --git a/pom.xml b/pom.xml index 03a35cbf..092d7a4f 100644 --- a/pom.xml +++ b/pom.xml @@ -861,7 +861,7 @@ com.zto.bigdata cluster-env - 1.0.4-SNAPSHOT + 1.0.5-SNAPSHOT -- Gitee From 029607eb168acbedeca83047a1490528270c0a9e Mon Sep 17 00:00:00 2001 From: zhanggougou <15651908511@163.com> Date: Tue, 27 May 2025 10:44:31 +0800 Subject: [PATCH 3/3] =?UTF-8?q?[fire-1224]=20=E5=B0=8F=E7=89=88=E6=9C=AC?= =?UTF-8?q?=E5=8D=87=E7=BA=A7=EF=BC=8C=E9=85=8D=E7=BD=AE=E4=B8=AD=E5=BF=83?= =?UTF-8?q?=E6=8E=A5=E5=8F=A3=E5=8D=87=E7=BA=A7=E5=8F=8Acluster-env?= =?UTF-8?q?=E5=8D=87=E7=BA=A7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/zto/fire/common/util/ConfigurationCenterManager.scala | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/fire-common/src/main/scala/com/zto/fire/common/util/ConfigurationCenterManager.scala b/fire-common/src/main/scala/com/zto/fire/common/util/ConfigurationCenterManager.scala index c12ecd86..dd72cde6 100644 --- a/fire-common/src/main/scala/com/zto/fire/common/util/ConfigurationCenterManager.scala +++ b/fire-common/src/main/scala/com/zto/fire/common/util/ConfigurationCenterManager.scala @@ -75,6 +75,7 @@ private[fire] object ConfigurationCenterManager extends Serializable with Loggin * 通过参数调用指定的接口 */ private[this] def invoke(url: String, param: String): String = { + logInfo(s"开始调用接口：$url,参数为：$param") try { HttpClientUtils.doPost(url, param,new Header(FireFrameworkConf.configCenterZdpHeaderKey,FireFrameworkConf.configCenterZdpHeaderValue)) } catch { @@ -104,6 +105,9 @@ private[fire] object ConfigurationCenterManager extends Serializable with Loggin if (param.isStatus && noEmpty(param, param.getResult) ) { this.configCenterProperties.putAll(param.getResult) logInfo("配置中心参数已生效") + } else{ + logError(s"配置中心接口未生效导致任务发布失败。请直接联系平台管理人员确认。 接口返回为：$json") + FireUtils.exitError } } this.configCenterProperties -- Gitee