Kaynağa Gözat

fix: kafka数据合并flag

许家凯 4 yıl önce
ebeveyn
işleme
05df9739e0
1 değiştirilmiş dosya ile 6 ekleme ve 6 silme
  1. 6 6
      jobs/task-step01.yaml

+ 6 - 6
jobs/task-step01.yaml

@@ -44,7 +44,7 @@ job:
             project: winhc_eci_dev
             source: winhc_eci.inc_ods_company_patent_pre
             target: winhc_eci_dev.inc_ods_company_patent
-            falg: 0
+            flag: 0
 
       #终本案件增量合并
       - taskName: inc_ods_company_zxr_final_case_pre
@@ -53,7 +53,7 @@ job:
             project: winhc_eci_dev
             source: winhc_eci.inc_ods_company_zxr_final_case_pre
             target: winhc_eci_dev.inc_ods_company_zxr_final_case
-            falg: 0
+            flag: 0
       #失信人增量合并
       - taskName: inc_ods_company_dishonest_info_pre
         param:
@@ -61,7 +61,7 @@ job:
             project: winhc_eci_dev
             source: winhc_eci.inc_ods_company_dishonest_info_pre
             target: winhc_eci_dev.inc_ods_company_dishonest_info
-            falg: 0
+            flag: 0
       #执行人增量合并
       - taskName: inc_ods_company_zxr_pre
         param:
@@ -69,7 +69,7 @@ job:
             project: winhc_eci_dev
             source: winhc_eci.inc_ods_company_zxr_pre
             target: winhc_eci_dev.inc_ods_company_zxr
-            falg: 0
+            flag: 0
 
       #开庭公告增量合并
       - taskName: inc_ods_company_court_open_announcement_pre
@@ -78,7 +78,7 @@ job:
             project: winhc_eci_dev
             source: winhc_eci.inc_ods_company_court_open_announcement_pre
             target: winhc_eci_dev.inc_ods_company_court_open_announcement
-            falg: 0
+            flag: 0
       #企业银行帐户增量合并
       - taskName: inc_ods_company_account_with_bank_pre
         param:
@@ -86,7 +86,7 @@ job:
             project: winhc_eci_dev
             source: winhc_eci.inc_ods_company_account_with_bank_pre
             target: winhc_eci_dev.inc_ods_company_account_with_bank
-            falg: 1
+            flag: 1
   #------<企业cid、自然人身份证补全:Spark
   - project: winhc_test
     flow: company_person_info_completion