23.DataStream API之State & Fault Tolerance(State Backends)

flink 1.9

State Backends

Flink提供了不同的狀态後端，用于指定狀态存儲的方式和位置。

狀态可以位于Java的堆上，也可以位于堆外。根據您的狀态後端，Flink還可以管理應用程式的狀态，這意味着Flink處理記憶體管理(如果必要的話可能溢出到磁盤)，以允許應用程式儲存非常大的狀态。預設情況下，可以通過配置檔案flink-conf.yaml确定所有Flink作業的狀态後端。

但是，可以根據每個作業重寫預設狀态後端，如下所示。

有關可用狀态後端、它們的優點、限制和配置參數的更多資訊，請參見部署和操作中的相應部分Deployment & Operations。

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

Want to contribute translation?

https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/stream/state/state_backends.html

https://flink.sojb.cn/dev/stream/state/state_backends.html