diff --git a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/SynchronizationActionBase.java b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/SynchronizationActionBase.java index 21f6c6b3e7ed..2b9b08917700 100644 --- a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/SynchronizationActionBase.java +++ b/paimon-flink/paimon-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 optionChanges = dynamicOptions.entrySet().stream()