Ming Li created FLINK-32655: ------------------------------- Summary: RecreateOnResetOperatorCoordinator did not forward notifyCheckpointAborted to the real OperatorCoordinator Key: FLINK-32655 URL: https://issues.apache.org/jira/browse/FLINK-32655 Project: Flink Issue Type: Bug Components: Runtime / Checkpointing Affects Versions: 1.17.1 Reporter: Ming Li
{{[RecreateOnResetOperatorCoordinator|https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/RecreateOnResetOperatorCoordinator.java#L115]}} does not override {{{}notifyCheckpointAborted{}}}, which causes the {{SplitEnumerator}} in {{SourceCoordinator}} can not receive the checkpoint abort message. -- This message was sent by Atlassian Jira (v8.20.10#820010)