Flink checkpoint
2021-07-19 14:23:22 38 举报Flink checkpoint
作者其他创作
大纲/内容
Job Manager
B
D
partition offset
4
source#2
c1
Checkpoint c1
E
operator id
state data
source#1
kafka#1 partition offset
operator#1
2
8
c3
sink#1
5
3
kafka#2 partition offset
Task Manager#1
sink#2
state
9
G
6
K
c2
F
kafka#1
7
H
插入checkpoint id 为 c2 的 barrier
插入checkpoint id 为 c3 的 barrier
kafka#2
C
A
1
J
operator#2
I
数据流向
checkpoint id 为 c1 的 barrier
Task Manager#2
插入checkpoint id 为 c1 的 barrier
state
插入checkpoint id 为 c4 的 barrier
Job Manager 定时往所有数据源的流中插入带checkpoint id 的 barrier
归属 checkpoint c2的数据
...
checkpoint id 为 c2 的 barrier
Checkpoint c3
Checkpoint c2
c4
status Backend
存储
0 条评论
下一页
