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

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

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

Shang Yuanchun (Jira)
Ufuk Celebi created FLINK-14145:
-----------------------------------

             Summary: getLatestCheckpoint 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


The flag to prefer checkpoints for recovery introduced in FLINK-11159 breaks returns the wrong checkpoint as the latest one if enabled.

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.

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)