[cdc] Avoid duplicate schema file generation (#4220)

apache · Sep 19, 2024 · 626b320 · 626b320
1 parent 12d6db5
commit 626b320
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/SynchronizationActionBase.java b/...flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/SynchronizationActionBase.java
@@ -198,6 +198,10 @@ protected FileStoreTable alterTableOptions(Identifier identifier, FileStoreTable
                                         || Objects.equals(
                                                 oldOptions.get(entry.getKey()), entry.getValue()));
 
+        if (dynamicOptions.isEmpty()) {
+            return table;
+        }
+
         // alter the table dynamic options
         List<SchemaChange> optionChanges =
                 dynamicOptions.entrySet().stream()