状态后端简介

Flink 依靠其状态后端来管理和检查timers计时器和keyed state的存储。
image.png
注意,state backends仅用来管理keyed state。Non-keyed state (常常用于sources、sinks, 或者broadcast state) 总是存储在jvm heap中。

Flink有2种状态后端:一种是基于heap内存对象,一种是基于RocksDB,一种将状态持久化到本地磁盘的开源嵌入式kv存储库(library)。

如何选择状态后端

image.png
因为一些历史原因,Flink1.13版本前我们会看到一些其他说法,实际上是混淆了state backend + checkpoint storage,这里统一一下:image.png