RestartStrategies & checkpoints

classic Classic list List threaded Threaded
3 messages Options
Reply | Threaded
Open this post in threaded view
|

RestartStrategies & checkpoints

aviad
Hi,

if my job configured with setRestartStrategy and with enableCheckpointing (&enableExternalizedCheckpoints).
it case of failure and job restart, does it restart with the latest checkpoint or is it restarts without any checkpoint.
Reply | Threaded
Open this post in threaded view
|

Re: RestartStrategies & checkpoints

Stefan Richter
Hi,

if the restart strategy that you set is configured to do restarts and you have checkpoints enabled, it will try to recover from the latest checkpoint. Is there any confusing point in the documentation that made this unclear for you, which we could improve?

Best, 
Stefan

Am 15.11.2017 um 14:30 schrieb Aviad Rotem <[hidden email]>:

Hi,

if my job configured with setRestartStrategy and with enableCheckpointing (&enableExternalizedCheckpoints).
it case of failure and job restart, does it restart with the latest checkpoint or is it restarts without any checkpoint.

Reply | Threaded
Open this post in threaded view
|

Re: RestartStrategies & checkpoints

aviad
Hi Stefan,

thanks for your answer.
I should have probably understand this behavior from
https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/restart_strategies.html#overview
"If checkpointing is not enabled, the “no restart” strategy is used. If
checkpointing is activated and the restart strategy has not been configured,
the fixed-delay strategy is used with Integer.MAX_VALUE restart attempts."

but still it is not written literally

thanks
Aviad




--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/