[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

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


for starting a job from the state of a previous job you should look into savepoints:

Checkpoints are only meant for faul tolerance within one execution of a job.


On 3. Oct 2018, at 08:10, wpb <307558207@xxxxxx> wrote:

    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?