[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

How to update Flink applications gracefully

Hi all

Now I'm trying to update my streaming application.
But I have no idea how to update it gracefully.

Should I stop it, replace a jar file then restart it?
In my understanding, in that case, all the state will be recovered if I use checkpoints in a persistent storage.
Is this correct?

Thank you,