[ https://issues.apache.org/jira/browse/FLINK-16945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168439#comment-17168439 ]
Biao Liu commented on FLINK-16945: ---------------------------------- [~dian.fu], yes, I'm working on this. It depends on some other issues which I'm preparing PRs. > 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)