The GitHub Actions job "Flink CDC CI" on flink-cdc.git/FLINK-38334 has failed. Run started by GitHub user morozov (triggered by yuxiqian).
Head commit for run: 672384e1576455bb995fab31ccb5b55b569aa68a / Sergei Morozov <[email protected]> FLINK-38334: Fix MySQL CDC source stuck in INITIAL_ASSIGNING 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. Report URL: https://github.com/apache/flink-cdc/actions/runs/22624878396 With regards, GitHub Actions via GitBox
