From 31d2da9d354877abe07998459970b57b803abb14 Mon Sep 17 00:00:00 2001
From: OT-XY <ptsxndg@gmail.com>
Date: Thu, 21 Sep 2023 16:57:42 +0800
Subject: [PATCH] [hotfix-#1827][kudu]Fix flinksql kudu write mode parameter
 does not take effect

---
 .../chunjun/connector/kudu/table/KuduDynamicTableFactory.java   | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/chunjun-connectors/chunjun-connector-kudu/src/main/java/com/dtstack/chunjun/connector/kudu/table/KuduDynamicTableFactory.java b/chunjun-connectors/chunjun-connector-kudu/src/main/java/com/dtstack/chunjun/connector/kudu/table/KuduDynamicTableFactory.java
index 3d4308f4a0..856e052c66 100644
--- a/chunjun-connectors/chunjun-connector-kudu/src/main/java/com/dtstack/chunjun/connector/kudu/table/KuduDynamicTableFactory.java
+++ b/chunjun-connectors/chunjun-connector-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);