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