×

scala

Flink / Scala 实践 - 11.大规模状态 ValueState 内存实践与优化

李杰 李杰 发表于2024-05-13 浏览4761 评论0
一.引言 前面讲到了 Flink - 大规模状态 ValueState IO 实践与优化,工业场景下 Flink 经常使用 ValueState + RocksDBStateBackend 的组合,由于 RocksDBStateBackend IO 侧的压力,对于状态访问 QPS 过高的任务,需将状态后端转换至 HashMapStateBackend,但是受限于 JVM Heap 的容量,大规模状态 ValueState 任务还需继续进行优化。 二.ValueState + HashMa