[ https://issues.apache.org/jira/browse/FLINK-7719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Stefan Richter closed FLINK-7719. --------------------------------- Resolution: Fixed Fix Version/s: 1.5.0 Merged in 402a2e30c750e1bcb753643ed66c6df0dd861112. > Send checkpoint id to task as part of deployment descriptor when resuming > ------------------------------------------------------------------------- > > Key: FLINK-7719 > URL: https://issues.apache.org/jira/browse/FLINK-7719 > Project: Flink > Issue Type: Improvement > Components: State Backends, Checkpointing > Affects Versions: 1.4.0 > Reporter: Stefan Richter > Assignee: Stefan Richter > Priority: Major > Fix For: 1.5.0 > > > As a preparation for local recovery, we need to make the tasks aware of the > checkpoint id from which they are supposed to recover. Currently, tasks only > get the state handles from which they will recover and do not have any > information from which checkpoint those states handles have been produced. > For local recovery, the tasks must identify the matching local state on their > own and need the checkpoint id for this. > The plan is to simply make the checkpoint id part of the task deployment > descriptor. -- This message was sent by Atlassian JIRA (v7.6.3#76005)