特牛生活网

Flink Yarn Per Job - 启动TM,向RM注册,RM分配solt_为什么flink要用自己的rm,每次jobmaster直接向yarn的rm申请资源不是更快-CSDN博客

网友收藏
  • 链接地址: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
  • 被收藏次数:7807
文章浏览阅读351次。通过Rpc服务,启动 TaskExecutor,找 它的 onStart()方法。开始注册,注册成功之后,调用 onRegistrationSuccess()分配完之后,通知 TaskManager提供 slot给 JobMaster。终端的启动,实际上是由 自身网关(RpcServer)来启动的。根据 RM的命令,分配taskmanager上的slot。连接上job, 向JobManager提供 slot。TaskManager 提供slot。创建和注册 新的这些 slot。启动TaskManager。._为什么flink要用自己的rm,每次jobmaster直接向yarn的rm申请资源不是更快