[FLINK-11667] Add Synchronous Checkpoint handling in StreamTask

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.8.0
• Fix Version/s: 1.9.0
• Component/s: Runtime / Checkpointing
• Labels: pull-request-available
• Assignee: Kostas Kloudas
• Reporter: Kostas Kloudas
• Created: 20/Feb/19 08:22
• Updated: 17/Apr/19 13:18
• Resolved: 17/Apr/19 13:18

Description

This is the basic building block for the SUSPEND/TERMINATE functionality.

In case of a synchronous checkpoint barrier, the checkpointing thread will block (without holding the checkpoint lock) until the notifyCheckpointComplete is executed successfully. This will allow the checkpoint to be considered successful ONLY when also the notifyCheckpointComplete is successfully executed.