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?

Reply via email to