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
----
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
