Flink 学习（一）：容错机制

Introduce Apache Flink 提供了可以恢复数据流应用到一致状态的容错机制。确保在发生故障时，程序恢复时，数据流的每一条记录只会被处理一次（exactly-once），当然也可以降级为至少处理一次（at-least-once）。 容错机制通过持续创建分布式数据流的快照来实现。对于状态占用空间小的流应用，这些快照非常轻量，可以高频率创建而对性能影响很小。流计算应用的状态保存在一个可配

>>阅读原文<<