Kostas Kloudas created FLINK-11667: -------------------------------------- Summary: Add Synchronous Checkpoint handling in StreamTask Key: FLINK-11667 URL: https://issues.apache.org/jira/browse/FLINK-11667 Project: Flink Issue Type: Sub-task Components: State Backends, Checkpointing Reporter: Kostas Kloudas Assignee: Kostas Kloudas
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. -- This message was sent by Atlassian JIRA (v7.6.3#76005)