Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-7719

Send checkpoint id to task as part of deployment descriptor when resuming

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 1.4.0
    • Fix Version/s: 1.5.0
    • Labels:
      None

      Description

      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.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                srichter Stefan Richter
                Reporter:
                srichter Stefan Richter
              • Votes:
                0 Vote for this issue
                Watchers:
                4 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: