This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a commit to branch release-0.4 in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git
commit 3571da6ffbcd1525f666ab3fa6f182960d789415 Author: zhengshubin <[email protected]> AuthorDate: Wed Apr 26 16:56:02 2023 +0800 [flink][bug] cdc sync action : mysql delete sync error (#1032) --- .../src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecord.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecord.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecord.java index 3bc5a563c..265ca72ff 100644 --- a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecord.java +++ b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecord.java @@ -94,7 +94,7 @@ public class CdcRecord implements Serializable { * returned */ public Optional<GenericRow> toGenericRow(List<DataField> dataFields) { - GenericRow genericRow = new GenericRow(dataFields.size()); + GenericRow genericRow = new GenericRow(this.kind, dataFields.size()); List<String> fieldNames = dataFields.stream().map(DataField::name).collect(Collectors.toList());
