Ted Yu created FLINK-4437: ----------------------------- Summary: Lock evasion around lastTriggeredCheckpoint may lead to lost updates to related fields Key: FLINK-4437 URL: https://issues.apache.org/jira/browse/FLINK-4437 Project: Flink Issue Type: Bug Reporter: Ted Yu
In CheckpointCoordinator#triggerCheckpoint(): {code} // make sure the minimum interval between checkpoints has passed if (lastTriggeredCheckpoint + minPauseBetweenCheckpoints > timestamp) { {code} If two threads evaluate 'lastTriggeredCheckpoint + minPauseBetweenCheckpoints > timestamp' in close proximity before lastTriggeredCheckpoint is updated, the two threads may have an inconsistent view of "lastTriggeredCheckpoint" and updates to fields correlated with "lastTriggeredCheckpoint" may be lost. -- This message was sent by Atlassian JIRA (v6.3.4#6332)