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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
