[ 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)