Stefan Richter created FLINK-7719:
-------------------------------------
Summary: 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
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
(v6.4.14#64029)