This is an automated email from the ASF dual-hosted git repository.
kunni pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/master by this push:
new 2712b49e3 [FLINK-37979][minor][mysql] Remove obsolete MySQL CDC
snapshot split assigner code (#4048)
2712b49e3 is described below
commit 2712b49e33d59d64270f6d6b9c7b2c9d7c2a8a5a
Author: Sergei Morozov <moro...@tut.by>
AuthorDate: Tue Sep 16 05:32:12 2025 -0700
[FLINK-37979][minor][mysql] Remove obsolete MySQL CDC snapshot split
assigner code (#4048)
---
.../mysql/source/assigners/MySqlSnapshotSplitAssigner.java | 10 +---------
1 file changed, 1 insertion(+), 9 deletions(-)
diff --git
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssigner.java
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssigner.java
index e295fb51f..1acbeac94 100644
---
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssigner.java
+++
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssigner.java
@@ -271,18 +271,10 @@ public class MySqlSnapshotSplitAssigner implements
MySqlSplitAssigner {
// case 2: there are new tables to add
if (!newlyAddedTables.isEmpty()) {
- // if job is still in snapshot reading phase, directly add
all newly added
- // tables
LOG.info("Found newly added tables, start capture newly
added tables process");
- // add new tables
remainingTables.addAll(newlyAddedTables);
- if (AssignerStatus.isAssigningFinished(assignerStatus)) {
- // start the newly added tables process under binlog
reading phase
- LOG.info(
- "Found newly added tables, start capture newly
added tables process under binlog reading phase");
- this.startAssignNewlyAddedTables();
- }
+ this.startAssignNewlyAddedTables();
}
} catch (Exception e) {
throw new FlinkRuntimeException(
