morozov opened a new pull request, #4278: URL: https://github.com/apache/flink-cdc/pull/4278
When a table is excluded from configuration after a restart from savepoint, the MySQL CDC source could get stuck in the INITIAL_ASSIGNING state. This happened because table exclusion cleanup was only performed when `isAssigningFinished()` was `true`, but the assigner couldn't finish because excluded table splits were never reported as finished. The fix separates two concerns in `captureNewlyAddedTables()`: - Adding new tables: should only happen when `isAssigningFinished()` - Removing excluded tables: must happen regardless of assigner status Added integration test `TableExclusionDuringSnapshotIT` that reproduces the issue by using a blocking hook to take a savepoint during `INITIAL_ASSIGNING` phase, then restarting with a table excluded from configuration. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
