Quellcode durchsuchen

简易注销3个表的增量同步

晏永年 vor 4 Jahren
Ursprung
Commit
e724f6eb35
2 geänderte Dateien mit 29 neuen und 13 gelöschten Zeilen
  1. 29 0
      jobs/task-step02.yaml
  2. 0 13
      src/main/resources/task-step02.yaml

+ 29 - 0
jobs/task-step02.yaml

@@ -311,6 +311,35 @@ job:
             dupliCols: new_cid,case_no
             flag: cid
             updateCol: case_create_time
+  #------<简易注销:Spark
+  - project: winhc_test
+    flow: incr_calc_intellectual_without_md5
+    task:
+      - taskName: company_brief_cancel_announcement
+        param:
+          - _nodeId: 700003483308
+            project: winhc_eci_dev
+            tableName: company_brief_cancel_announcement
+            dupliCols: new_cid,id
+            flag: cid
+  #------>
+  #------<简易注销-结果:Spark
+      - taskName: company_brief_cancel_announcement_result
+        param:
+          - _nodeId: 700003483308
+            project: winhc_eci_dev
+            tableName: company_brief_cancel_announcement_result
+            dupliCols: new_cid,main_id,id
+            flag: cid
+  #------>
+  #------<简易注销-异议:Spark
+      - taskName: company_brief_cancel_announcement_objection
+        param:
+          - _nodeId: 700003483308
+            project: winhc_eci_dev
+            tableName: company_brief_cancel_announcement_objection
+            dupliCols: new_cid,main_id,id
+            flag: cid
   #------>
   - project: winhc_test
     flow: inc_company_mapping

+ 0 - 13
src/main/resources/task-step02.yaml

@@ -356,16 +356,3 @@ job:
             tableName: company_copyright_works_list
             cidField: new_cid
             dupliCols: new_cid,reg_num
-      #简易注销
-      - taskName: company_brief_cancel_announcement_result
-        param:
-          - _nodeId: 700003375026
-            project: winhc_eci_dev
-            tableName: company_brief_cancel_announcement_result
-            dupliCols: new_cid,brief_cancel_result,announcement_apply_date
-            flag: cid
-          - _nodeId: 700003380225
-            project: winhc_eci_dev
-            tableName: company_brief_cancel_announcement_result
-            cidField: new_cid
-            dupliCols: new_cid,brief_cancel_result,announcement_apply_date