rakulang, dartlang, nimlang, golang, rustlang, lang lang no see

状态后端

焉知非鱼

State Backends

状态后端 #

Flink 提供了不同的状态后端,指定状态的存储方式和位置。

状态可以位于 Java 的堆上或离堆(off-heap)。根据你的状态后端,Flink 还可以为应用程序管理状态,这意味着 Flink 处理内存管理(必要时可能会溢出到磁盘),以允许应用程序持有非常大的状态。默认情况下,配置文件 flink-conf.yaml 决定了所有 Flink 作业(job)的状态后端。

然而,默认的状态后端可以在每个作业(per-job)的基础上被重写,如下所示。

有关可用的状态后端、其优势、限制和配置参数的更多信息,请参见部署与操作中的相应章节。

val env = StreamExecutionEnvironment.getExecutionEnvironment()
env.setStateBackend(...)

状态后端: https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/stream/state/state_backends.html