Nico Kruber created FLINK-18955:
-----------------------------------
Summary: Add snapshot path to job startup message
Key: FLINK-18955
URL: https://issues.apache.org/jira/browse/FLINK-18955
Project: Flink
Issue Type: Improvement
Components: Runtime / Coordination
Affects Versions: 1.11.1
Reporter: Nico Kruber
When a job is started from a checkpoint or savepoint (I'm using snapshot as the
unanimous term below), the {{CheckpointCoordinator}} prints a log line like
this:
{code}
2020-08-13 13:50:51,418 INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Restoring job
220d8a4953cd40198b6eb3b1ec0cece0 from latest valid checkpoint: Checkpoint 357 @
1597326576925 for 220d8a4953cd40198b6eb3b1ec0cece0.
{code}
I propose to add the path to the snapshot to this message because which
snapshot is taken for restore may actually not be that obvious for the user:
even if a savepoint was specified in the job start command, e.g. in a
Kubernetes pod spec, an HA store could overrule the decision and take a more
recent snapshot instead. If that snapshot is a savepoint, it is not that easy
to map this to checkpoint IDs and find out which savepoint the job actually
started from.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
