Apache Flink fault tolerance源碼剖析(六)

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

>>阅读原文<<