[doris-flink-connector] branch branch-for-flink-before-1.13 updated: fix setting error (#192)

[diwu]

This is an automated email from the ASF dual-hosted git repository.

diwu pushed a commit to branch branch-for-flink-before-1.13
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git


The following commit(s) were added to refs/heads/branch-for-flink-before-1.13 
by this push:
     new db20f65  fix setting error (#192)
db20f65 is described below

commit db20f65c7811a7d3e4bf8a2fe9691a2cc60221fe
Author: wanshicheng <wanshich...@qq.com>
AuthorDate: Mon Sep 18 09:54:11 2023 +0800

    fix setting error (#192)
---
 .../java/org/apache/doris/flink/table/DorisDynamicOutputFormat.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 @@ public class DorisDynamicOutputFormat<T> extends 
RichOutputFormat<T> {
     }
 
     private boolean enableBatchDelete() {
-        return executionOptions.getEnableDelete() || 
UNIQUE_KEYS_TYPE.equals(keysType);
+        return executionOptions.getEnableDelete() && 
UNIQUE_KEYS_TYPE.equals(keysType);
     }
 
     @Override


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org