Flink状态一致性

一、状态一致性分类 （1）最多一次（at most once） 当故障发生，什么都不干，既不恢复丢失状态，也不重播丢失的数据。 （2）至少一次（at least once） 所有事件都处理了，有的事件可能被处理多次 （3）精确一次（exactly once） 所有事件仅仅被处理一次 二、端到端的状态一致性 （1）内部保证（checkpoint） （2）source端（可重设数据的读取位置） （3）

>>阅读原文<<