Question about Checkpoint
Posted by
ZalaCheung on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Question-about-Checkpoint-tp14009.html
Hi Flink Community,
I am new to Flink and now looking at checkpoint of Flink.
After reading the document, I am still confused. Here is scene:
I have a datastream finally flow to a database sink. I will update one of the field in database based on the incomming stream. I have now complete a snapshot, say t1, and snapshot t2 is on progress. After snapshot t1 complete, I update my database several times. Then BEFORE snapshot t2 complete, my task fail.
Based on my understanding of checkpoint on Flink, I will recover from snapshot t1 and re-execute the Streams between t1 and t2. But I've already update my database several times after t1. Does flink deal with this issue?
Best,
Desheng Zhang