(paimon) branch master updated: [cdc] Avoid duplicate schema file generation (#4220)

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 626b32007 [cdc] Avoid duplicate schema file generation (#4220)
626b32007 is described below

commit 626b320075d287b1acbfacda5881ed28c1a4f8bb
Author: DBG <linux_...@163.com>
AuthorDate: Thu Sep 19 21:55:00 2024 +0800

    [cdc] Avoid duplicate schema file generation (#4220)
---
 .../org/apache/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 21f6c6b3e..2b9b08917 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 @@ public abstract class SynchronizationActionBase extends 
ActionBase {
                                         || Objects.equals(
                                                 
oldOptions.get(entry.getKey()), entry.getValue()));
 
+        if (dynamicOptions.isEmpty()) {
+            return table;
+        }
+
         // alter the table dynamic options
         List<SchemaChange> optionChanges =
                 dynamicOptions.entrySet().stream()