Flink状态存储?
发布时间:2022-09-02 15:42:17
发布人:wjy
Flink在做计算的过程中经常需要存储中间状态,来避免数据丢失和状态恢复。选择的状态存储策略不同,会影响状态持久化如何和 checkpoint 交互。
Flink提供了三种状态存储方式:
MemoryStateBackend
FsStateBackend
RocksDBStateBackend。
下一篇Flink窗口?