commit

src/main/java/com/jz/dmp/cmdexectool/scheduler/common/task/sync/SyncParameters.java

@@ -321,8 +321,8 @@ public class SyncParameters extends AbstractParameters {
         //# 存储模式，支持overwrite、append、update、ignore、error
         jdbcSinkModel.put("save_mode", targetObj.get("targetInsertMergeOverwrite"));
         //当存储模式是 overwrite时，仅清除表中数据
-        if (null != targetObj.get("targetInsertMergeOverwrite")) {
-            if ("overwrite".equals(targetObj.get("targetInsertMergeOverwrite"))) {
+        if (null != targetObj.get("primaryKeyConflict")) { //主键冲突
+            if ("overwrite".equals(targetObj.get("primaryKeyConflict"))) {
                 jdbcSinkModel.put("truncate", "true");
             } else {
                 jdbcSinkModel.put("truncate", "false");