网站介绍：文章浏览阅读351次。通过Rpc服务，启动 TaskExecutor，找 它的 onStart()方法。开始注册，注册成功之后，调用 onRegistrationSuccess()分配完之后，通知 TaskManager提供 slot给 JobMaster。终端的启动，实际上是由 自身网关（RpcServer）来启动的。根据 RM的命令，分配taskmanager上的slot。连接上job， 向JobManager提供 slot。TaskManager 提供slot。创建和注册 新的这些 slot。启动TaskManager。._为什么flink要用自己的rm,每次jobmaster直接向yarn的rm申请资源不是更快
- 链接地址：https://blog.csdn.net/hyunbar/article/details/126165327
- 链接标题：Flink Yarn Per Job - 启动TM，向RM注册，RM分配solt_为什么flink要用自己的rm,每次jobmaster直接向yarn的rm申请资源不是更快-CSDN博客
- 所属网站：blog.csdn.net
- 被收藏次数：3098
- 网站标签：为什么flink要用自己的rm 每次jobmaster直接向yarn的rm申请资源不是更快
