赞
踩
Flink在做计算的过程中经常需要存储中间状态,来避免数据丢失和状态恢复。选择的状态存储策略不同,会影响状态持久化如何和checkpoint交互。
Flink提供了三种状态存储方式:
MemoryStateBackend、FsStateBackend、RocksDBStateBackend。