状态后台

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

State可以位于Java堆上或堆外。根据您的状态后台，Flink还可以管理应用程序的状态，这意味着Flink处理内存管理（如果需要可能会溢出到磁盘）以允许应用程序保持非常大的状态。默认情况下，配置文件flink-conf.yaml确定所有Flink作业的状态后台。

但是，可以在每个作业的基础上覆盖默认状态后台，如下所示。

有关可用状态后台，其优点，限制和配置参数的详细信息，请参阅部署和 算子操作中的相应部分。

• Java
• Scala

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

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