From 8146dac7875248199eb5d2707e2f34ea2f75295b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E4=B8=8D=E4=BC=9A=E8=AF=B4=E8=AF=9D=E7=9A=84=E6=9C=BA?=
 =?UTF-8?q?=E5=99=A8=E7=8C=AB?= <646659000@qq.com>
Date: Mon, 6 Nov 2023 18:04:20 +0800
Subject: [PATCH] =?UTF-8?q?[fire-1086]=E8=8E=B7=E5=8F=96=E8=A1=80=E7=BC=98?=
 =?UTF-8?q?=E4=BF=A1=E6=81=AF=E5=A4=B1=E8=B4=A5=E4=BF=AE=E5=A4=8DMismatche?=
 =?UTF-8?q?dInputException=E5=BC=82=E5=B8=B8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/zto/fire/flink/rest/FlinkSystemRestful.scala      | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/fire-engines/fire-flink/src/main/scala/com/zto/fire/flink/rest/FlinkSystemRestful.scala b/fire-engines/fire-flink/src/main/scala/com/zto/fire/flink/rest/FlinkSystemRestful.scala
index b359f2e..34a2300 100644
--- a/fire-engines/fire-flink/src/main/scala/com/zto/fire/flink/rest/FlinkSystemRestful.scala
+++ b/fire-engines/fire-flink/src/main/scala/com/zto/fire/flink/rest/FlinkSystemRestful.scala
@@ -87,9 +87,11 @@ private[fire] class FlinkSystemRestful(var baseFlink: BaseFlink, val restfulRegi
     try {
       this.logger.debug(s"内部请求分布式更新血缘信息，ip：${request.ip()}")
       LineageManager.printLog(s"请求fire更新血缘信息：$json")
-      val lineageMap = JSONUtils.parseObject[JConcurrentHashMap[Datasource, JHashSet[DatasourceDesc]]](json)
-      if (ValueUtils.noEmpty(lineageMap)) {
-        FlinkLineageAccumulatorManager.add(lineageMap)
+      if (noEmpty(json)) {
+        val lineageMap = JSONUtils.parseObject[JConcurrentHashMap[Datasource, JHashSet[DatasourceDesc]]](json)
+        if (ValueUtils.noEmpty(lineageMap)) {
+          FlinkLineageAccumulatorManager.add(lineageMap)
+        }
       }
       ResultMsg.buildSuccess("血缘信息已更新", ErrorCode.SUCCESS.toString)
     } catch {
-- 
Gitee