Flink 广播状态 - RocksDB 状态后端
Flink broadcast state - RocksDB state backend
在广播模式的文档中,提到没有 RocksDB 状态后端:
No RocksDB state backend: Broadcast state is kept in-memory at runtime and memory provisioning should be done accordingly. This holds for all operator states.
如果应用程序使用 rocksdb 作为状态后端,这对保存点行为有何影响?这是否意味着状态在保存点期间未存储,因此未恢复?
广播状态包含在保存点和检查点中。
Flink 区分 keyed 和 non-keyed 状态。 Flink 管理的所有状态,包括键控和非键控,都包含在保存点和检查点中。
广播状态是一种非键控状态,和所有非键控状态一样,不存储在 RocksDB 中。当 RocksDB 用作状态后端时,这意味着键控状态的工作状态保存在 RocksDB 中,而不是堆上。当拍摄状态快照(即保存点或检查点)时,来自 RocksDB 的状态加上所有非键控状态 被写入快照。
在广播模式的文档中,提到没有 RocksDB 状态后端:
No RocksDB state backend: Broadcast state is kept in-memory at runtime and memory provisioning should be done accordingly. This holds for all operator states.
如果应用程序使用 rocksdb 作为状态后端,这对保存点行为有何影响?这是否意味着状态在保存点期间未存储,因此未恢复?
广播状态包含在保存点和检查点中。
Flink 区分 keyed 和 non-keyed 状态。 Flink 管理的所有状态,包括键控和非键控,都包含在保存点和检查点中。
广播状态是一种非键控状态,和所有非键控状态一样,不存储在 RocksDB 中。当 RocksDB 用作状态后端时,这意味着键控状态的工作状态保存在 RocksDB 中,而不是堆上。当拍摄状态快照(即保存点或检查点)时,来自 RocksDB 的状态加上所有非键控状态 被写入快照。