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)

Reply via email to