fix

apache · Apr 7, 2024 · a1080a6 · a1080a6
1 parent e4ae4d2
commit a1080a6
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/...src/main/java/org/apache/paimon/flink/sink/cdc/CdcDynamicTableParsingProcessFunction.java b/...src/main/java/org/apache/paimon/flink/sink/cdc/CdcDynamicTableParsingProcessFunction.java
@@ -107,7 +107,7 @@ public void processElement(T raw, Context context, Collector<Void> collector) th
                         });
 
         List<DataField> schemaChange = parser.parseSchemaChange();
-        if (schemaChange.size() > 0) {
+        if (!schemaChange.isEmpty()) {
             context.output(
                     DYNAMIC_SCHEMA_CHANGE_OUTPUT_TAG,
                     Tuple2.of(Identifier.create(database, tableName), schemaChange));

diff --git a/...link/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/RichEventParser.java b/...link/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/RichEventParser.java
@@ -20,6 +20,7 @@
 
 import org.apache.paimon.types.DataField;
 
+import java.util.ArrayList;
 import java.util.Collections;
 import java.util.List;
 
@@ -35,7 +36,7 @@ public void setRawEvent(RichCdcRecord rawEvent) {
 
     @Override
     public List<DataField> parseSchemaChange() {
-        return record.fields();
+        return new ArrayList<>(record.fields());
     }
 
     @Override