commit db20f65c7811a7d3e4bf8a2fe9691a2cc60221fe
author wanshicheng <wanshicheng@qq.com> Mon Sep 18 09:54:11 2023 +0800
committer GitHub <noreply@github.com> Mon Sep 18 09:54:11 2023 +0800
tree 5a07a66bdf3a0ebf933920ce4bf83fa4fd49c98c
parent 154bcf4161ba29a90d9d0603c241dda85ff85901

fix setting error (#192)

flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicOutputFormat.java

diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicOutputFormat.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicOutputFormat.java
index 3f51df6..065eb18 100644
--- a/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicOutputFormat.java
+++ b/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicOutputFormat.java
@@ -177,7 +177,7 @@
     }
 
     private boolean enableBatchDelete() {
-        return executionOptions.getEnableDelete() || UNIQUE_KEYS_TYPE.equals(keysType);
+        return executionOptions.getEnableDelete() && UNIQUE_KEYS_TYPE.equals(keysType);
     }
 
     @Override