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)
