Flink- 状态后端作用 -11
1.状态后端作用
状态后端负责 2 件事:本地状态管理和将状态以检查点的形式写入远程存储
2.本地状态管理
(1)状态后端会存储所有键值分区状态,并保证能将状态访问范围正确地限制在当前值
(2)键值状态作为对象,以内存数据结构形式存在于 JVM 中,优点快,但是不能太大
(3)状态对象序列化后存放到 RocksDB,写到本地硬盘,优点不受大小限制,缺点就是比较慢一些
3.将状态以检查点形式写入远程存储
(1)Flink 是一个分布系统,但是只在本地维护状态,所以状态检查点显得特别重要
(2)RocksDB 状态后端支持增量检查点
(3)不同状态后端生成状态检查点的方式也存在差异
评论