第 22 节 Flink 状态、恢复、快照

上篇：第 21 节　Flink Distributed Cache(分布式缓存) 1、Flink 状态(State)管理与恢复 （1）状态(State) 我们前面写的wordcount的例子，没有包含状态管理。如果一个task在处理过程中挂掉了，那么它在内存中的状态都会丢失，所有的数据都需要重新计算。从容错和消息处理的语义上(at least once, exactly once)，Flink引入

>>阅读原文<<