Stephan Ewen created FLINK-4417:
-----------------------------------

             Summary: Checkpoints should be subsumed by CheckpointID not, by 
timestamp
                 Key: FLINK-4417
                 URL: https://issues.apache.org/jira/browse/FLINK-4417
             Project: Flink
          Issue Type: Bug
          Components: State Backends, Checkpointing
    Affects Versions: 1.1.2
            Reporter: Stephan Ewen
             Fix For: 1.2.0


Since the system clocks cannot be expected to be stable/monotonous, the 
subsumption logic in the checkpoint coordinator should not decide which 
checkpoint is "newer" based on the system time.

The checkpoint ID is guaranteed to be strictly monotonously increasing. It is a 
better measure to decide which checkpoint is newer.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to