Flink 檢查點(checkpoint)

Flink具體如何保證exactly-once呢? 它使用一種被稱爲"檢查點"(checkpoint)的特性,在出現故障時將系統重置回正確狀態。下面通過簡單的類比來解釋檢查點的作用。 假設你和兩位朋友正在數項鍊上有多少顆珠子,如下圖所示。你捏住珠子,邊數邊撥,每撥過一顆珠子就給總數加一。你的朋友也這樣數他們手中的珠子。當你分神忘記數到哪裏時,怎麼辦呢? 如果項鍊上有很多珠子,你顯然不想從頭再數一遍
相關文章
相關標籤/搜索