Stephan Ewen created FLINK-15922:
------------------------------------
Summary: Show "Warn - received late message for checkpoint" only when checkpoint actually expired
Key: FLINK-15922
URL:
https://issues.apache.org/jira/browse/FLINK-15922 Project: Flink
Issue Type: Improvement
Components: Runtime / Checkpointing
Affects Versions: 1.10.0
Reporter: Stephan Ewen
Fix For: 1.11.0
The message "Warn - received late message for checkpoint" is shown frequently in the logs, also when a checkpoint was purposefully canceled.
In those case, this message is unhelpful and misleading.
We should log this only when the checkpoint is actually expired.
Meaning that when receiving the message, we check if we have an expired checkpoint for that ID. If yes, we log that message, if not, we simply drop the message.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)