Re: Job recovery from a checkpoint

Posted by Yun Tang on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Job-recovery-from-a-checkpoint-tp29937p29938.html

Hi Min

First of all, Flink could resume from an externalized checkpoint with same command as restoring from savepoint.

• Did you make the externalized checkpoint retained after job canceled?
  
• Did you really pass the correct checkpoint path (including chk-xxx folder) to the command line?
  

If you really pass the correct path, please check the jobmanager log to see what happened, did it restore from the checkpoint you want?

Best

Yun Tang

---

From: [hidden email] <[hidden email]>
Sent: Thursday, September 12, 2019 0:37
To: [hidden email] <[hidden email]>
Subject: Job recovery from a checkpoint

 

Hi,

 

We can get a job recovery from a save point nicely after a restart of our flink cluster using

bin/flink run -s :savepointPath [:runArgs]

The previous job states are recovered after this reload.

I expect I do something similar to recover a flink from a checkpoint location after a restart of our flink cluster (job manager and task manager) using

bin/flink run  –s  checkpointPath/_metadata  [:runArgs]

It seems that our reloaded job does not keep the previous states of the job.

 

Do I do something wrong? I suppose this is doable and no additional configuration is required?

 

Regards,

 

Min