[doris-flink-connector] branch master updated: [improvement] fix uniq delete operation (#63)

[diwu]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 4d07fb6  [improvement] fix uniq delete operation (#63)
4d07fb6 is described below

commit 4d07fb6f7804fb4fe7522e69cac06f3b99e3e7de
Author: wudi <676366...@qq.com>
AuthorDate: Mon Sep 26 09:40:12 2022 +0800

    [improvement] fix uniq delete operation (#63)
    
    fix uniq delete operation
---
 .../src/main/java/org/apache/doris/flink/rest/RestService.java          | 2 +-
 .../main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java   | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java
 
b/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java
index 2f93f95..21900b4 100644
--- 
a/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java
+++ 
b/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java
@@ -440,7 +440,7 @@ public class RestService implements Serializable {
     public static boolean isUniqueKeyType(DorisOptions options, 
DorisReadOptions readOptions, Logger logger)
             throws DorisRuntimeException {
         try {
-            return "UNIQUE_KEYS_TYPE".equals(getSchema(options, readOptions, 
logger).getKeysType());
+            return UNIQUE_KEYS_TYPE.equals(getSchema(options, readOptions, 
logger).getKeysType());
         } catch (Exception e) {
             throw new DorisRuntimeException(e);
         }
diff --git 
a/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java
 
b/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java
index 53d727f..572e09c 100644
--- 
a/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java
+++ 
b/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java
@@ -77,7 +77,7 @@ public class DorisDynamicTableSink implements 
DynamicTableSink {
     @Override
     public SinkRuntimeProvider getSinkRuntimeProvider(Context context) {
         Properties loadProperties = executionOptions.getStreamLoadProp();
-        boolean deletable = RestService.isUniqueKeyType(options, readOptions, 
LOG) || executionOptions.getDeletable();
+        boolean deletable = RestService.isUniqueKeyType(options, readOptions, 
LOG) && executionOptions.getDeletable();
         if (!loadProperties.containsKey(COLUMNS_KEY)) {
             String[] fieldNames = tableSchema.getFieldNames();
             Preconditions.checkState(fieldNames != null && fieldNames.length > 
0);


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