From 626b320075d287b1acbfacda5881ed28c1a4f8bb Mon Sep 17 00:00:00 2001
From: DBG <linux_dbg@163.com>
Date: Thu, 19 Sep 2024 21:55:00 +0800
Subject: [PATCH] [cdc] Avoid duplicate schema file generation (#4220)

---
 .../paimon/flink/action/cdc/SynchronizationActionBase.java    | 4 ++++
 1 file changed, 4 insertions(+)

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<SchemaChange> optionChanges =
                 dynamicOptions.entrySet().stream()