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
E-mail: gzzhangdesh...@corp.netease.com;

Reply via email to