I've read the doc about Flink's checkpointing mechanism from Data Streaming Fault Tolerance, and I wonder how does it ensure the exactly once semantics. Consider there is a Flink job with checkpoint enabled and the interval of checkpointing is 500ms. If the last completed checkpoint is n and after that, a few records have been computed and then the job failed before the next checkpoint.So are these records will be recomputed after the job recovery.
0 Answers
Related