状态后台

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

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

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

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

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

回到顶部