diff --git a/fire-common/src/main/scala/com/zto/fire/common/lineage/LineageManager.scala b/fire-common/src/main/scala/com/zto/fire/common/lineage/LineageManager.scala
index 2c240277569348ef01f53917a52b5e510f69d72f..de335be9dcd1871c3c420eec9d0d2a022b3c6ae0 100644
--- a/fire-common/src/main/scala/com/zto/fire/common/lineage/LineageManager.scala
+++ b/fire-common/src/main/scala/com/zto/fire/common/lineage/LineageManager.scala
@@ -930,7 +930,7 @@ object LineageManager extends Logging {
   /**
    * 将目标DataSourceDesc中的operation合并到set中
    */
-  private[fire] def mergeSet(set: JHashSet[DatasourceDesc], datasourceDesc: DatasourceDesc): Unit = {
+  private[fire] def mergeSet(set: JHashSet[DatasourceDesc], datasourceDesc: DatasourceDesc): Unit = this.synchronized {
     if (set.isEmpty || !set.contains(datasourceDesc)) {
       set.add(datasourceDesc)
       return