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)) {