[
https://issues.apache.org/jira/browse/FLINK-20406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-20406.
----------------------------------
Resolution: Fixed
Fixed in
- 1.13.0 (master) via 856d4ea3cabce335f25ed163df8ae8eba9680890
- 1.12.0 (release-1.12) via 519c0a6c812c71173939735572fd6865e304e8e4
> 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)
