[Flink]Fix create table options (#436)

* Support concurrent writing of non-primary key tables Signed-off-by: ChenYunHey <[email protected]> * fix flink tests Signed-off-by: ChenYunHey <[email protected]> * fix flink tests Signed-off-by: ChenYunHey <[email protected]> * Flink API create table Signed-off-by: ChenYunHey <[email protected]> --------- Signed-off-by: ChenYunHey <[email protected]>
lakesoul-io · Jan 29, 2024 · 4e4b415 · 4e4b415
1 parent af58737
commit 4e4b415
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lakesoul-flink/src/main/java/org/apache/flink/lakesoul/metadata/LakeSoulCatalog.java b/lakesoul-flink/src/main/java/org/apache/flink/lakesoul/metadata/LakeSoulCatalog.java
@@ -249,7 +249,7 @@ public void createTable(ObjectPath tablePath, CatalogBaseTable table, boolean ig
                         uniqueConstraint -> String.join(LAKESOUL_HASH_PARTITION_SPLITTER,
                                 uniqueConstraint.getColumns()))
                 .orElse("");
-        Map<String, String> tableOptions = table.getOptions();
+        Map<String, String> tableOptions = new HashMap<>(table.getOptions());
 
         // adding cdc options
         if (!"".equals(primaryKeys)) {