Apache Flink fault tolerance源碼剖析(六)

上篇文章我們分析了基於檢查點的用戶狀態的保存機制——狀態終端。這篇文章我們來分析barrier（中文常譯爲柵欄或者屏障，爲了避免引入名稱爭議，此處仍用英文表示）。檢查點的barrier是提供exactly once一致性保證的主要保證機制。這篇文章我們會就此展開分析。 這篇文章我們側重於核心代碼分析，原理我們在這個系列的第一篇文章《Flink數據流的Fault Tolerance機制》 一致性保證

>>阅读原文<<