[mysql] Skip ddl events in snapshot split normalization (#577)

3 years ago · 75276235dc
parent 8ba9b70e88
commit 75276235dc
1 changed files with 7 additions and 5 deletions
--- a/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/utils/RecordUtils.java
+++ b/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/utils/RecordUtils.java
@ -110,11 +110,13 @@ public class RecordUtils {
                List<SourceRecord> allBinlogRecords =
                        sourceRecords.subList(i, sourceRecords.size() - 1);
                for (SourceRecord binlog : allBinlogRecords) {
-                    Object[] key =
-                            getSplitKey(snapshotSplit.getSplitKeyType(), binlog, nameAdjuster);
-                    if (splitKeyRangeContains(
-                            key, snapshotSplit.getSplitStart(), snapshotSplit.getSplitEnd())) {
-                        binlogRecords.add(binlog);
+                    if (isDataChangeRecord(binlog)) {
+                        Object[] key =
+                                getSplitKey(snapshotSplit.getSplitKeyType(), binlog, nameAdjuster);
+                        if (splitKeyRangeContains(
+                                key, snapshotSplit.getSplitStart(), snapshotSplit.getSplitEnd())) {
+                            binlogRecords.add(binlog);
+                        }
                    }
                }
            }