文章浏览阅读114次。Flink 的状态一致性什么是状态一致性• 有状态的流处理，内部每个算子任务都可以有自己的状态• 对于流处理器内部来说，所谓的状态一致性，其实就是我们所说的计算结果要保证准确。• 一条数据不应该丢失，也不应该重复计算• 在遇到故障时可以恢复状态，恢复以后的重新计算，结果应该也是完全正确的。状态一致性分类• AT-MOST-ONCE（最多一次）➢ 当任务故障时，最简单的做法是什么都不干，既不恢复丢失的状态，也不重播丢失的数据。At-most-once 语义的含义是最多处理一次事件。• A_哪些sink可以用 2pc