Flink StateBackend - DefaultOperatorStateBackend

Liao Jiayi Liao Jiayi #Flink#Apache Flink

Since the existing StateBackend implementations only override KeyedStateBackend, all Operator State uses DefaultOperatorStateBackend for snapshots.

Translated from Chinese with AI · Read the original

Since the existing StateBackend implementations only override KeyedStateBackend, all Operator State uses DefaultOperatorStateBackend for snapshots.

Overview

The state in DefaultOperatorStateBackend falls into two main categories:

  • PartitionableListState
  • BackendWritableBroadcastState

Reading and Writing State

State Snapshots

State Recovery