AI
推荐
模板社区
专题
登录
免费注册
首页
流程图
详情
Flink checkpoint
2021-07-19 14:23:22
40
举报
分享方式
免费使用
Flink checkpoint
flink
模版推荐
作者其他创作
大纲/内容
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
存储
收藏
立即使用
Flink checkpoint
收藏
立即使用
kafka 架构
收藏
立即使用
软件开发流程
收藏
立即使用
eureka region zone
wqlm
职业：博士
去主页
Collect
Get Started
Flink
Collect
Get Started
Apache Flink核心概念思维导图
Collect
Get Started
Flink Checkpoint
Collect
Get Started
flink pipe
评论
0
条评论
下一页
Document
