添加状态后端
This commit is contained in:
parent
1ccae8417a
commit
bbf92c0480
@ -140,6 +140,44 @@ Flink 为算子状态提供三种基本数据结构:
|
|||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
# 状态后端实现
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
StateBackend实现类图,在1.17版本中,部分状态后端已经过期,比如:~~MemoryStateBackend~~、~~RocksDBStateBackend~~、~~FsStateBackend~~等。
|
||||||
|
|
||||||
|
![pic](https://pan.zeekling.cn//flink/basic/state/StateBackend_0002.png)
|
||||||
|
|
||||||
|
去除掉已经过期的状态后端剩余的如下所示:
|
||||||
|
|
||||||
|
![pic](https://pan.zeekling.cn//flink/basic/state/StateBackend_0003.png)
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
## HashMapStateBackend
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
## EmbeddedRocksDBStateBackend
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
## ChangelogStateBackend
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
## DeactivatedChangelogStateBackend
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
# 常见报错
|
# 常见报错
|
||||||
|
|
||||||
## The maximum number of queued checkpoint requests exceeded
|
## The maximum number of queued checkpoint requests exceeded
|
||||||
|
Loading…
Reference in New Issue
Block a user