From c4f6d26848c83766840be6c8dbc87e7754ce7331 Mon Sep 17 00:00:00 2001 From: Sergei Morozov Date: Fri, 20 Jun 2025 17:47:10 -0700 Subject: [PATCH] [FLINK-37979] Remove obsolete MySQL CDC snapshot split assigner code --- .../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 e295fb51fdb..1acbeac941b 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 @@ private void captureNewlyAddedTables() { // 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(