Apache Flink数据流的Fault Tolerance机制

简介 Apache Flink提供了一个失败恢复机制来使得数据流应用能够持续得恢复状态。这个机制能够保证即便线上环境的失败，程序的状态也将能保证数据流达到exactly once的一致性。注意这里也能够选择降级到保证at least once的一致性级别。html 失败恢复机制持续地构建分布式流式数据的快照。对于那些只有少许状态的流处理应用，这些快照都是很是轻量级的而且能够以很是频繁的频率来构建快

>>阅读原文<<