[FLINK-32655] RecreateOnResetOperatorCoordinator did not forward notifyCheckpointAborted to the real OperatorCoordinator

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.17.1
• Fix Version/s: 1.18.0, 1.16.3, 1.17.2
• Component/s: Runtime / Checkpointing
• Labels: pull-request-available
• Assignee: Ming Li
• Reporter: Ming Li
• Created: 24/Jul/23 07:38
• Updated: 26/Jul/23 02:07
• Resolved: 26/Jul/23 02:07

Description

RecreateOnResetOperatorCoordinator does not override notifyCheckpointAborted, which causes the SplitEnumerator in SourceCoordinator can not receive the checkpoint abort message.

 

Issue Links

• links to: GitHub Pull Request #23059
• links to: GitHub Pull Request #23070
• links to: GitHub Pull Request #23071