Flink| 状态一致性

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

>>阅读原文<<