AI
推荐
模板社区
专题
登录
免费注册
首页
流程图
详情
Flink运行时组件
2022-01-21 14:50:45
32
举报
分享方式
免费使用
Flink运行时组件
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
收藏
立即使用
JVM的内存布局
收藏
立即使用
JVM内存布局
收藏
立即使用
JVM空间分配担保
收藏
立即使用
锁升级同步
易先生
职业：软件工程师
去主页
Collect
Get Started
JVM运行时数据区
Collect
Get Started
运行时
Collect
Get Started
JVM组成（类加载器/运行时数据区）
Collect
Get Started
运行时库
评论
0
条评论
下一页
Document
