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

Posted to dev@flink.apache.org by "Biao Liu (Jira)" <ji...@apache.org> on 2019/08/30 06:37:00 UTC

[jira] [Created] (FLINK-13905) Separate checkpoint triggering into stages

Biao Liu created FLINK-13905:
--------------------------------

             Summary: Separate checkpoint triggering into stages
                 Key: FLINK-13905
                 URL: https://issues.apache.org/jira/browse/FLINK-13905
             Project: Flink
          Issue Type: Sub-task
          Components: Runtime / Coordination
            Reporter: Biao Liu
             Fix For: 1.10.0


Currently {{CheckpointCoordinator#triggerCheckpoint}} includes some heavy IO operations. We plan to separate the triggering into different stages. The IO operations are executed in IO threads, while other on-memory operations are not.

This is a preparation for making all on-memory operations of {{CheckpointCoordinator}} single threaded (in main thread).
Note that we could not put on-memory operations of triggering into main thread directly now. Because there are still some operations on a heavy lock (coordinator-wide).



--
This message was sent by Atlassian Jira
(v8.3.2#803003)