Flink Exactly Once

Flink Exactly Once Flink Exactly Once 語意是基於Chandy-Lamport這個算法的思想的改進版，引入了barrier，可以在不停止整個流處理系統的前提下，保存和恢復每個subtask的snapshot，讓每個節點獨立地做狀態保存和恢復。 Chandy-Lamport 算法 Initiating a snapshot: 也就是開始創建 snapshot，可以

>>阅读原文<<