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
