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)