From 4e4b4159bf90bfa522c510025695f6f1fe629099 Mon Sep 17 00:00:00 2001 From: ChenYunHey <90120383+ChenYunHey@users.noreply.github.com> Date: Mon, 29 Jan 2024 20:04:47 +0800 Subject: [PATCH] [Flink]Fix create table options (#436) * Support concurrent writing of non-primary key tables Signed-off-by: ChenYunHey <1908166778@qq.com> * fix flink tests Signed-off-by: ChenYunHey <1908166778@qq.com> * fix flink tests Signed-off-by: ChenYunHey <1908166778@qq.com> * Flink API create table Signed-off-by: ChenYunHey <1908166778@qq.com> --------- Signed-off-by: ChenYunHey <1908166778@qq.com> --- .../org/apache/flink/lakesoul/metadata/LakeSoulCatalog.java | 2 +- 1 file changed, 1 insertion(+), 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 index 17216fefe..bee04b993 100644 --- 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 tableOptions = table.getOptions(); + Map tableOptions = new HashMap<>(table.getOptions()); // adding cdc options if (!"".equals(primaryKeys)) {