Check pureBinlogPhaseTables set before call getBinlogPosition method …

…in BinlogSplitReader
apache · Sep 23, 2024 · f041189 · f041189
1 parent b710750
commit f041189
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/.../java/org/apache/flink/cdc/connectors/mysql/debezium/task/MySqlSnapshotSplitReadTask.java b/.../java/org/apache/flink/cdc/connectors/mysql/debezium/task/MySqlSnapshotSplitReadTask.java
@@ -282,6 +282,7 @@ private BinlogOffset createDataEventsForTable(
                                 snapshotSplit.getSplitKeyType().getFieldCount(),
                                 sourceConfig.getFetchSize())
              ) {
+
             selectStatement.execute();
             ResultSet rs = selectStatement.getResultSet();