[hotfix-#1827][kudu]Fix flinksql kudu write mode parameter does not t…

…ake effect
DTStack · Sep 21, 2023 · 31d2da9 · 31d2da9
1 parent 49c6873
commit 31d2da9
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...-kudu/src/main/java/com/dtstack/chunjun/connector/kudu/table/KuduDynamicTableFactory.java b/...-kudu/src/main/java/com/dtstack/chunjun/connector/kudu/table/KuduDynamicTableFactory.java
@@ -44,6 +44,7 @@
 import static com.dtstack.chunjun.connector.kudu.table.KuduOptions.SCANNER_BATCH_SIZE_BYTES;
 import static com.dtstack.chunjun.connector.kudu.table.KuduOptions.TABLE_NAME;
 import static com.dtstack.chunjun.connector.kudu.table.KuduOptions.WORKER_COUNT;
+import static com.dtstack.chunjun.connector.kudu.table.KuduOptions.WRITE_MODE;
 import static com.dtstack.chunjun.lookup.options.LookupOptions.LOOKUP_ASYNC_TIMEOUT;
 import static com.dtstack.chunjun.lookup.options.LookupOptions.LOOKUP_CACHE_MAX_ROWS;
 import static com.dtstack.chunjun.lookup.options.LookupOptions.LOOKUP_CACHE_PERIOD;
@@ -146,6 +147,7 @@ public Set<ConfigOption<?>> optionalOptions() {
         optionalOptions.add(SINK_BUFFER_FLUSH_INTERVAL);
         optionalOptions.add(SINK_MAX_RETRIES);
         optionalOptions.add(SINK_PARALLELISM);
+        optionalOptions.add(WRITE_MODE);
 
         // kerberos
         optionalOptions.add(PRINCIPAL);