Flink 容錯性機制- 屏障（barrier）實現原理

    我們知道Flink提供了容錯機制，能夠在應用失敗的時候重新恢復任務。這個機制主要就是通過持續產生快照的方式實現的。Flink快照主要包括兩部分數據一部分是數據流的數據，另一部分是operator的狀態數據。對應的快照機制的實現有主要兩個部分組成，一個是屏障(Barrier），一個是狀態(State)。因爲Flink這裏處理的數據流，數據在多個operator的DAG拓撲中持續流動，要想實現

>>阅读原文<<