状态后端

状态后端 #

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