State Backends

原文链接

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

状态可以位于Java的堆内或堆外。根据你的状态后端，Flink可以管理应用程序的状态，这意味着Flink处理内存管理(如果必要的话会溢出到磁盘)来允许应用持有非常大的状态。默认情况下，配置文件flink-conf.yaml决定所有Flink作业的状态后端。

然而，默认的状态后端可以基于每个任务进行覆盖，具体步骤如下所示。

关于可用的状态后端的更多信息，它们的优点、限制和配置参数请见Deployment & Operations。

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