【12】Flink 之 状态(State)管理与CheckPoint容错恢复

一、状态(State)管理与恢复 1.一、状态(State) 咱们前面写的word count的例子，没有包含状态管理。若是一个task在处理过程当中挂掉了，那么它在内存中的状态都会丢失，全部的数据都须要从新计算。从容错和消息处理的语义上(at least once, exactly once)，Flink引入了state和 checkpoint。 首先区分一下两个概念 state通常指一个具体的

>>阅读原文<<