Flink运行时整体流程图
2021-12-09 10:20:44 2 举报登录查看完整内容
Flink运行时整体流程图
作者其他创作
大纲/内容
TaskManager
Task
1.启动Session Cluster
StateBackend（Heap/Rocksdb）
Standalone Cluster
SlotManager
7.启动TaskManager
Application Master
4.为JobGraph创建JobManager
5.请求Slot资源
ClientCompiler/Optimizer
ResourceManager
ExecutionGraph
10.提供Slot资源
Yarn
Shuffle
8.启动后注册Slot信息
6.判断现有资源是否满足要求如果不满足，则向外部集群资源管理器动态申请资源如果满足，则可直接进行下一步启动TaskManager
Dispatcher
3.提交JobGraph
11.提交Task
K8s
JobGraph
JobManager
代码
9.申请Slot资源
Worker
Cluster Management
2.启动Application Master
收藏
0 条评论
回复 删除
下一页
