Flink到底能不能實現exactly-once語義

關於這個問題其實從一開始很多人是存在質疑的,首先exactly-once語義指的是即使在出現故障的情況下,Flink流應用程序中的所有算子都保證事件只會被"精確一次"(恰好一次,不多不少)的處理.假設有下面一個場景,Flink在完成了一次checkpoint後,第二次checkpoint前(此時兩個checkpoint中間的數據已經處理了一部分了)任務掛掉了,然後任務恢復的時候會從上一次成功的ch

>>阅读原文<<