|
Hi All,
The setup of my flink application is allow user to start and stop.
The Flink job is running in job cluster (application jar is available to
flink upon startup). When stop a running application, it means exit the
program.
When restart a stopped job, it means to spin up new job cluster with the
same application jar, but this essentially means a new flink job.
I just wonder is there a way to let the restarted job resume from the
latest checkpoint from previous stopped flink job? And is there a way to
set it up programmatically in the application?
Thanks a lot!
Eleanore
|