codehaus


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

Re: How to update Flink applications gracefully


Hi Yuta,

You can use cancel-with-savepoint to stop you application and save the state in a savepoint, then update your jar and restart the application from the saved savepoint. Checkpointing is an automatic mechanism to recover from runtime failures and savepoints are designed for manual restart. See the following:

https://ci.apache.org/projects/flink/flink-docs-release-1.7/ops/state/savepoints.html



Kind regards,

Nastaran Motavalli




From: Yuta Morisawa <yu-morisawa@xxxxxxxxxxxxxxxx>
Sent: Tuesday, December 18, 2018 6:30:09 AM
To: user@xxxxxxxxxxxxxxxx
Subject: 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,