Flink Exactly Once

Flink Exactly Once Flink Exactly Once 语意是基于Chandy-Lamport这个算法的思想的改进版，引入了barrier，可以在不停止整个流处理系统的前提下，保存和恢复每个subtask的snapshot，让每个节点独立地做状态保存和恢复。 Chandy-Lamport 算法 Initiating a snapshot: 也就是开始创建 snapshot，可以

>>阅读原文<<