You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "tchivs (via GitHub)" <gi...@apache.org> on 2026/10/16 06:05:51 UTC

[PR] [FLINK-41010][cdc-base] Roll back assigner status when failed snapshot splits are re-added [flink-cdc]

tchivs opened a new pull request, #4581:
URL: https://github.com/apache/flink-cdc/pull/4581

   ## What is the purpose of the change
   Same defect as FLINK-40052 (#4459, MySQL only) in flink-cdc-base: re-added snapshot splits do not roll back the assigner status, so the stream split is built while their finished offsets are missing and fails with an NPE.
   
   ## Brief change log
   - SnapshotSplitAssigner#addSplits rolls back *_FINISHED to the matching assigning status and clears checkpointIdToFinish.
   
   ## Verifying this change
   New SnapshotSplitAssignerTest covers both INITIAL_ASSIGNING_FINISHED and NEWLY_ADDED_ASSIGNING_SNAPSHOT_FINISHED; both fail on master (e.g. "expected: INITIAL_ASSIGNING but was: INITIAL_ASSIGNING_FINISHED") and pass with the change.
   


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org