[FLINK-13905] Separate checkpoint triggering into stages

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.11.0
• Component/s: Runtime / Checkpointing
• Labels: pull-request-available
• Assignee: Biao Liu
• Reporter: Biao Liu
• Created: 30/Aug/19 06:36
• Updated: 21/Jan/20 08:17
• Resolved: 21/Jan/20 08:17

Description

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).

Issue Links

• links to: GitHub Pull Request #10332