flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Timo Walther <twal...@apache.org>
Subject Re: Does job restart resume from last known internal checkpoint?
Date Wed, 31 May 2017 14:17:36 GMT
Hi Moiz,

yes the job will be restartet in case of failure using the last 
successful checkpoint. If you cancel the job, the checkpoints will be 
discarded. That's why Flink has savepoints [1] in order to store 
checkpoints permantently (with additional meta-information). If there is 
no checkpoint/savepoint, the job would start with empty state in all 
operators which also means that Kafka offets are reset.

If you are interested in checkpointing internals, you can find more 
information here [2].


[1] https://data-artisans.com/blog/turning-back-time-savepoints

Am 30.05.17 um 18:47 schrieb Moiz S Jinia:
> In a checkpointed Flink job will doing a graceful restart make it 
> resume from last known internal checkpoint? Or are all checkpoints 
> discarded when the job is stopped?
> If discarded, what will be the resume point?
> Moiz

View raw message