[
https://issues.apache.org/jira/browse/FLINK-14145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-14145:
--------------------------------
Description:
The flag to prefer checkpoints for recovery introduced in FLINK-11159 returns
the wrong checkpoint if:
* checkpoints are preferred ({{getLatestCheckpoint(true)}}),
* the latest checkpoint is *not* a savepoint,
* more than a single checkpoint is retained.
The current implementation assumes that the latest checkpoint is a savepoint
and skips over it. I attached a patch for
{{StandaloneCompletedCheckpointStoreTest}} that demonstrates the issue.
You can apply the patch via {{git am -3 < *.patch}}.
was:
The flag to prefer checkpoints for recovery introduced in FLINK-11159 returns
the wrong checkpoint if checkpoints are preferred
({{getLatestCheckpoint(true)}}) and the latest checkpoint is *not* a savepoint.
The current implementation assumes that the latest checkpoint is a savepoint
and skips over it. I attached a patch for
{{StandaloneCompletedCheckpointStoreTest}} that demonstrates the issue.
You can apply the patch via {{git am -3 < *.patch}}.
> getLatestCheckpoint(true) returns wrong checkpoint
> --------------------------------------------------
>
> Key: FLINK-14145
> URL: https://issues.apache.org/jira/browse/FLINK-14145
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Checkpointing
> Affects Versions: 1.9.0
> Reporter: Ufuk Celebi
> Priority: Major
> Attachments:
> 0001-FLINK-14145-runtime-Add-getLatestCheckpoint-test.patch
>
>
> The flag to prefer checkpoints for recovery introduced in FLINK-11159 returns
> the wrong checkpoint if:
> * checkpoints are preferred ({{getLatestCheckpoint(true)}}),
> * the latest checkpoint is *not* a savepoint,
> * more than a single checkpoint is retained.
> The current implementation assumes that the latest checkpoint is a savepoint
> and skips over it. I attached a patch for
> {{StandaloneCompletedCheckpointStoreTest}} that demonstrates the issue.
> You can apply the patch via {{git am -3 < *.patch}}.
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
