How can I confirm a savepoint is used for a new job?

classic Classic list List threaded Threaded
3 messages Options
Reply | Threaded
Open this post in threaded view
|

How can I confirm a savepoint is used for a new job?

Hao Sun
Do we have any logs in JM/TM indicate the job is using a savepoint I passed in when I submit the job?

Thanks
Reply | Threaded
Open this post in threaded view
|

Re: How can I confirm a savepoint is used for a new job?

Timo Walther
Hi Hao,

I quickly checked that manually. There should be a message similar to
the one below in the JobManager log:

INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator  -
Starting job from savepoint ...

Regards,
Timo

Am 22.03.18 um 06:45 schrieb Hao Sun:
> Do we have any logs in JM/TM indicate the job is using a savepoint I
> passed in when I submit the job?
>
> Thanks


Reply | Threaded
Open this post in threaded view
|

Re: How can I confirm a savepoint is used for a new job?

Hao Sun
Thanks Tim.

On Mon, Mar 26, 2018, 03:04 Timo Walther <[hidden email]> wrote:
Hi Hao,

I quickly checked that manually. There should be a message similar to
the one below in the JobManager log:

INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator  -
Starting job from savepoint ...

Regards,
Timo

Am 22.03.18 um 06:45 schrieb Hao Sun:
> Do we have any logs in JM/TM indicate the job is using a savepoint I
> passed in when I submit the job?
>
> Thanks