Skip to content

Commit c4f6d26

Browse files
committed
[FLINK-37979] Remove obsolete MySQL CDC snapshot split assigner code
1 parent 49fe26d commit c4f6d26

File tree

1 file changed

+1
-9
lines changed

1 file changed

+1
-9
lines changed

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssigner.java

Lines changed: 1 addition & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -271,18 +271,10 @@ private void captureNewlyAddedTables() {
271271

272272
// case 2: there are new tables to add
273273
if (!newlyAddedTables.isEmpty()) {
274-
// if job is still in snapshot reading phase, directly add all newly added
275-
// tables
276274
LOG.info("Found newly added tables, start capture newly added tables process");
277275

278-
// add new tables
279276
remainingTables.addAll(newlyAddedTables);
280-
if (AssignerStatus.isAssigningFinished(assignerStatus)) {
281-
// start the newly added tables process under binlog reading phase
282-
LOG.info(
283-
"Found newly added tables, start capture newly added tables process under binlog reading phase");
284-
this.startAssignNewlyAddedTables();
285-
}
277+
this.startAssignNewlyAddedTables();
286278
}
287279
} catch (Exception e) {
288280
throw new FlinkRuntimeException(

0 commit comments

Comments
 (0)