flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Stefan Richter (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-7719) Send checkpoint id to task as part of deployment descriptor when resuming
Date Wed, 27 Sep 2017 15:35:00 GMT
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)

Mime
View raw message