Have you tried to retain checkpoints or use savepoints? Take a look at [1] and see if that can help.
Best, Flavio [1] https://eventador.io/blog/apache-flink-checkpoints-and-savepoints/ Il Ven 13 Mar 2020, 00:02 Eleanore Jin <eleanore....@gmail.com> ha scritto: > 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 > > >
