Flink流式框架的状态一致性

一、状态一致性 1）有状态的流处理，内部每个算子任务都可以有自己的状态； 2）对于流处理器内部来说，所谓的状态一致性，其实就是我们所说的计算结果要保证准确； 3）一条数据不应该丢失，也不应该重复计算； 4）在遇到故障时可以恢复状态，恢复以后进行重新计算，结果应该也是完全正确的；   1、状态一致性分类 （1）AT-MOST-ONCE（最多一次）   》》当任务故障时，最简单的做法就是什么也不干，既

>>阅读原文<<