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)
