第三天:Flink的State、CheckPoint、Window窗口

5. Flink State管理跟恢复 Flink 是一个默认就有状态的分析引擎,前面的 WordCount 案例能够作到单词的数量的累加,实际上是由于在内存中保证了每一个单词的出现的次数,这些数据其实就是状态数据。可是若是一个 Task 在处理过程当中挂掉了,那么它在内存中的状态都会丢失,全部的数据都须要从新计算。从容错和消息处理的语义(At -least-once 和 Exactly-once
相关文章
相关标签/搜索