Stephan Ewen created FLINK-20406:
------------------------------------
Summary: Return the Checkpoint ID of the restored Checkpoint in
CheckpointCoordinator.restoreLatestCheckpointedStateToSubtasks()
Key: FLINK-20406
URL: https://issues.apache.org/jira/browse/FLINK-20406
Project: Flink
Issue Type: Sub-task
Components: Runtime / Checkpointing
Reporter: Stephan Ewen
Assignee: Stephan Ewen
Fix For: 1.12.0
To allow the scheduler to notify Operator Coordinators of subtask restores
(local failover), we need to know which checkpoint ID was restored.
This change does not adjust the other restore methods of the Checkpoint
Coordinator, because the fact that the Scheduler needs to be involved in the
subtask restore notification at all is only due to a shortcoming of the
Checkpoint Coordinator: The CC is not aware of subtask restores, it always
restores all subtasks and relies on the fact that assigning state to a running
execution attempt has no effect.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
