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].
Regards,
Timo
[1] https://data-artisans.com/blog/turning-back-time-savepoints
[2]
https://ci.apache.org/projects/flink/flink-docs-release-1.3/internals/stream_checkpointing.html
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
