0
点赞
收藏
分享

微信扫一扫

大数据_Flink_数据处理_运行时架构2_作业提交流程_抽象架构---Flink工作笔记0017

佃成成成成 2022-02-23 阅读 100

1.首先先去提交任务,这个提交任务可以是在网页端后台,也可以是在命令行提交任务。

在网页端后台提交就是flink的网页管理端对吧。

2.第1步任务将会被提交到分发器

3.第2步分发器会把任务转交给jobmanager,这里每提交过来一个任务就会启动对应一个作业管理器,所以每一个任务都会对应启动一个作业管理器来管理这个任务的执行。

4.第3步,作业管理器执行任务需要请求slot插槽,向resourcemanager资源管理器请求。

5.第4步,resourcemanager收到请求以后,首先去启动taskmanager,然后

第5步,taskmanager启动以后会向resourcemanager报告,有多少个可用的slot

第6步,resourcemanager得知有多少个slot可用以后,就开始向taskmanager发出

要求提供slot的指令。

6.第7步,taskmanager提供slot,然后再就是jobmanager提交任务到对应的提供

   slot的节点上执行。

举报

相关推荐

0 条评论