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 b359f2ed60582c51bd03591f3700cfe0003cde77..34a23005e009b2f64a74aaf2be52e827170bc395 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 {