You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/01/12 17:18:00 UTC

[jira] [Created] (FLINK-20943) AsyncCheckpointRunnable.cleanup() runs in the main task thread

Roman Khachatryan created FLINK-20943:
-----------------------------------------

             Summary: AsyncCheckpointRunnable.cleanup() runs in the main task thread
                 Key: FLINK-20943
                 URL: https://issues.apache.org/jira/browse/FLINK-20943
             Project: Flink
          Issue Type: Bug
          Components: Runtime / Checkpointing
    Affects Versions: 1.11.3, 1.12.0, 1.13.0
            Reporter: Roman Khachatryan
            Assignee: Roman Khachatryan
             Fix For: 1.13.0, 1.12.2


In FLINK-8871 an RPC notification about checkpoint abortion was added.

Upon receiving it, task cancels the running state-persisting futures. It does so through mailbox. Cancelling the futures may involve waiting for their result (if they can't be cancelled).

 

This essentially makes checkpoint sync from async upon such RPC.

 

cc [~yunta], [~pnowojski]



--
This message was sent by Atlassian Jira
(v8.3.4#803005)