Re: How can I set the Flink Job Id to enable flink checkpoint

2018-10-04 Thread Aljoscha Krettek
Hi, for starting a job from the state of a previous job you should look into savepoints: https://ci.apache.org/projects/flink/flink-docs-release-1.6/ops/state/savepoints.html Checkpoints are only meant for

How can I set the Flink Job Id to enable flink checkpoint

2018-10-02 Thread wpb
hello, When I enable the checkpoint in flink job, I found that flink have saved the checkpoint to the dir such as ${statebackend}/${jobId}. but after I restart the flink job, the job id is changed, so that the state does not restore correctly. How can I set the Flink Job Id in code?