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?
- How can I set the Flink Job Id to enable flink checkpoin... wpb
- Re: How can I set the Flink Job Id to enable flink ... Aljoscha Krettek