Flink 1.12 和 1.13 的状态后端差异
Flink1.12的状态后端
MemoryStateBackend
内部数据作为对象在java堆空间中存储。checkpoint时,状态快照发送给jobmanager。
FsStateBackend
文件系统状态后端将正在进行的数据保存在TaskManager内存中。检查点完成后,将状态快照保存到文件系统中。最小的元数据存储在JobManager的内存中(或在高可用性模式下,存储在元数据检查点中)。
RocksDBStateBackend
RocksDB状态后端将RocksDB数据库中的数据保存在TaskManager目录中。检查点完成后,整个数据库的数据将进入配置的目录。最小的元数据存储在JobManager的内存中(或在高可用性模式下,存储在元数据检查点中)。
Flink1.13的状态后端
HashMapStateBackend
EmbeddedRocksDBStateBackend
本文是原创文章,采用 CC BY-NC-ND 4.0 协议,完整转载请注明来自 shiyuquan.cn
评论
匿名评论
隐私政策
你无需删除空行,直接评论以获取最佳展示效果