问题一、什么是状态?
问题二、Flink状态类型有哪几种?
问题三、状态有什么作用?
问题四、如何使用状态,实现什么样的API?
问题五、什么是checkpoint与savepoint?
问题六、如何使用checkpoint与savepoint?
问题七、checkpoint原理是什么?
一、状态
定义:
某task/operator 在某一时刻的一个中间结果
快照(snapshot)
作用:
state可以被记录,在失败的情况下可以恢复。
基本类型:
Operator state
Keyed state
Flink提供一套状态保存的方法,无需在借助第三方存储系统来解决状态存储问题。
二、Flink状态类型有哪几种?
(1)Operator State
唯一绑定到特定operator
与key无关
提供的数据结构
ListState<T>
(2)Keyed State
基于KeyStream之上的状态,dataStream.keyBy()
KeyBy之后的Operator State
Organized by keyGroups
原文:https://www.cnblogs.com/ssqq5200936/p/11026735.html