Flink运行时组件
2022-01-21 14:50:45 31 举报Flink运行时组件
作者其他创作
大纲/内容
Flink Client
2. 提交Job
NodeManager
4. 启动5. 注册slots6. 发送提供slot的指令
Flink运行时的组件
4. 申请资源
HDFS
7. 提供slots8. 提交要在slots中执行的任务
Container
加载Flink的Jar和配置构建环境
Union
Task Slot
JobManager作业管理器
ApplicationMaster
Dispatcher
TaskManager
ResourceManager
Blink-sql
Source
flatMap
flink消费做数据统计
TaskManager任务管理器
9. 交换数据
Filter
KeyBy
JobManager
mysqlbinlog
APP
map
滚动聚合算子
kafka
Reduce
Transform
任务提交流程（YARN）
3. 请求slots
Dispacher分发器
任务提交流程
1. 提交应用
ResourceManager资源管理器
Split/Select
3. 启动ApplicationMaster
2. 启动并提交应用
1. 上传Flink的Jar包和配置
Connect/CoMap
5. 启动TaskManager
0 条评论
下一页
