You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Ufuk Celebi (Jira)" <ji...@apache.org> on 2019/09/20 08:12:00 UTC

[jira] [Updated] (FLINK-14145) getLatestCheckpoint(true) returns wrong checkpoint

     [ https://issues.apache.org/jira/browse/FLINK-14145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Ufuk Celebi updated FLINK-14145:
--------------------------------
    Summary: getLatestCheckpoint(true) returns wrong checkpoint  (was: getLatestCheckpoint returns wrong checkpoint)

> 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 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)