Flink新特性之非對齊檢查點（unaligned checkpoint）簡介

前言 在食用本文之前，建議看官先充分食用這兩篇文章：《Chandy-Lamport分佈式快照算法小記》與《深入理解Flink的輕量級異步屏障快照（ABS）算法》。 屏障對齊的風險 在Flink的檢查點機制中，屏障（barrier）是劃分快照（狀態）的邊界。在啓用exactly once語義的條件下，當一個算子有多個輸入流時，需要等待所有輸入流中當前檢查點N的屏障都到達其輸入緩衝區，才能安全地觸發檢

>>阅读原文<<