[
https://issues.apache.org/jira/browse/FLINK-6964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16064532#comment-16064532
]
ASF GitHub Bot commented on FLINK-6964:
---------------------------------------
GitHub user StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/4192
[FLINK-6964] [checkpoint] Fix externalized incremental checkpoints fo…
This PR fixes a problem that came up with incremental checkpoints and the
`StandaloneCompletedCheckpointStore`. After restoring from an externalized
incremental checkpoint, the following incremental checkpoints failed to pickup
the existing incremental states in the registry that have been restored from
the checkpoint. As a second problem, the used operator identifier in the
backend could change across restores.
This PR:
- registeres restored state from externalized checkpoints/savepoint with
the `SharedStateRegistry`
- introduced artifical backend identifiers to isolate files from differen
backends with the same file name in the {SharedStateRegistry}. In case of a
(non-rescaled) restore, the identifier is picked up again from the previous
state.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/StefanRRichter/flink
fixRecoverStandaloneCompeltedCheckpointStore
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/4192.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #4192
----
----
> Fix recovery for incremental checkpoints in StandaloneCompletedCheckpointStore
> ------------------------------------------------------------------------------
>
> Key: FLINK-6964
> URL: https://issues.apache.org/jira/browse/FLINK-6964
> Project: Flink
> Issue Type: Bug
> Components: State Backends, Checkpointing
> Reporter: Stefan Richter
> Assignee: Stefan Richter
>
> {{StandaloneCompletedCheckpointStore}} does not register shared states ion
> resume. However, for externalized checkpoints, it register the checkpoint
> from which it resumed. This checkpoint gets added to the completed checkpoint
> store as part of resume.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
