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 checkpoint. 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? Cheers, Gordon -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
