Hi Ashish,

Could you elaborate a bit more on why you think the restart of all operators
lead to data loss?

When restart occurs, Flink will restart the job from the latest complete
All operator states will be reloaded with state written in that checkpoint,
and the position of the input stream will also be re-winded.

I don't think there is a way to force a checkpoint before restarting occurs,
but as I mentioned, that should not be required, because the last complete
checkpoint will be used.
Am I missing something in your particular setup?


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

Reply via email to