2 things you can do,
stop flink job is going to generate savepoint.
You need to save the save point directory path in some persistent store
(because you are restarting the cluster, otherwise checkpoint monitoring
api should give you save point file details)
After spinning the cluster read the path
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 ha scritto:
> Hi All,
>
> The setup of my flink application is allow u
