实时流处理系统容错机制（二）：Apache Flink 基于State的异步容错机制

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

>>阅读原文<<