[
https://issues.apache.org/jira/browse/FLINK-20406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-20406.
--------------------------------
> 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
> Priority: Major
> 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)
