[ https://issues.apache.org/jira/browse/FLINK-16945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231320#comment-17231320 ]
Dian Fu commented on FLINK-16945: --------------------------------- [~AHeise] Thanks for the confirmation. > Execute CheckpointFailureManager.FailJobCallback directly in main thread > executor > --------------------------------------------------------------------------------- > > Key: FLINK-16945 > URL: https://issues.apache.org/jira/browse/FLINK-16945 > Project: Flink > Issue Type: Improvement > Components: Runtime / Checkpointing > Affects Versions: 1.10.0 > Reporter: Biao Liu > Assignee: Biao Liu > Priority: Critical > Labels: pull-request-available > Fix For: 1.12.0 > > Time Spent: 20m > Remaining Estimate: 0h > > Since we have put all non-IO operations of {{CheckpointCoordinator}} into > main thread executor, the {{CheckpointFailureManager.FailJobCallback}} could > be executed directly now. In this way execution graph would fail immediately > when {{CheckpointFailureManager}} invokes the callback. We could avoid the > inconsistent scenario of FLINK-13497. -- This message was sent by Atlassian Jira (v8.3.4#803005)