译者:flink.sojb.cn

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

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

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

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

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