专栏首页Flink-selfLearn13. 下-taskExecutor向RM注册自己的slot.png
原创

13. 下-taskExecutor向RM注册自己的slot.png

TE注册自己的slot report

13.2. taskExecutor向Rm注册自己的slot信息

DONE:

1. TaskExecutor在接收到注册成功之后, 发布一个事件

2. 在TaskExecutor的registryListenr内向RM报告自己的slot: sendSlotReport

TODO

1. resourceManager什么时候向TM申请slot.

总的图看起来应该是:

接下来看什么

本来想接着按照黑图(来自高赟的flink进阶文章)的资源管理流程看下一步, RM如何向TM申请slot.

但是, 我没有找到该怎么办, taskExecutor发送了自己的slotReport之后, 我就断了联系了, 看不到其他的了.

所以, 就在高赟的文章里找到Flink的集群的基本结构的那张图, 看它第三步, client给dispatcher提交自己的jobGraph之后该怎么办.

我觉得JobExecutor起来之后肯定会到slot的申请啊什么的, 慢慢看, 只要有线索, 跟着就跑就得了, 多条线跟上一条就把别的解开了.

Flink的集群的基本结构

原创声明,本文系作者授权云+社区发表,未经许可,不得转载。

如有侵权,请联系 yunjia_community@tencent.com 删除。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • Flink启动-13.TaskExecutor向RM注册自己

    wangyk
  • [源码解析] 从TimeoutException看Flink的心跳机制

    本文从一个调试时候常见的异常 "TimeoutException: Heartbeat of TaskManager timed out"切入,为大家剖析Fli...

    罗西的思考
  • 数栈技术分享:一文带你了解Flink jm、tm启动过程和资源分配

    4)在perJob模式下,最终调用的是YarnJobClusterEntrypoint

    数栈DTinsight
  • [源码解析] Flink的Slot究竟是什么?(1)

    Flink的Slot概念大家应该都听说过,但是可能很多朋友还不甚了解其中细节,比如具体Slot究竟代表什么?在代码中如何实现?Slot在生成执行图、调度、分配资...

    罗西的思考
  • Flink on YARN 基础架构与启动流程

    本文转载Flink官方社区文章:一张图轻松掌握 Flink on YARN 基础架构与启动流程

    神秘的寇先森
  • [源码解析] Flink的Slot究竟是什么?(2)

    Flink的Slot概念大家应该都听说过,但是可能很多朋友还不甚了解其中细节,比如具体Slot究竟代表什么?在代码中如何实现?Slot在生成执行图、调度、分配资...

    罗西的思考
  • Spring5源码 - 12 Spring事件监听机制_异步事件监听应用及源码解析

    Spring提供的事件机制,默认是同步的。如果想要使用异步事件监听,可以自己实现ApplicationEventMulticaster接口,并在Spring容器...

    小小工匠
  • 猫头鹰的深夜翻译:Spring线程 TaskExecutor

    在Spring中,我们可以额外注意并使用框架已经提供的工具,而不是创造我们自己的线程。

    眯眯眼的猫头鹰
  • flink源码分析之TaskManager启动篇

    客户端不是运行时和程序执行的一部分,但用于准备数据流并将其发送到JobManager。之后,客户端可以断开连接(分离模式 detached mode),或者保持...

    开发架构二三事
  • SpringBoot详细研究-01基础

    Springboot可以说是当前最火的java框架了,非常适合于"微服务"思路的开发,大幅缩短软件开发周期。 ? ? 概念 过去Spring充满了配置...

    用户1216676
  • 注册中心 Eureka 源码解析 —— Eureka-Server 集群同步

    Eureka-Server 可以使用直接配置所有节点的服务地址,或者基于 DNS 配置。推荐阅读:《Spring Cloud构建微服务架构(六)高可用服务注册中...

    芋道源码
  • Yarn快速系列入门(2) | Yarn的运行与工作流程

    不温卜火
  • 新手也能看懂的 SpringBoot 异步编程指南

    异步编程在处理耗时操作以及多任务处理的场景下非常有用,我们可以更好的让我们的系统利用好机器的 CPU 和 内存,提高它们的利用率。多线程设计模式有很多种,Fut...

    Guide哥
  • Flink 在有赞实时计算的实践

    其次是在调研阶段我们为什么选择了 Flink。在这个部分,主要是 Flink 与 Spark 的 structured streaming 的一些对比和选择 F...

    Fayson
  • 聊聊spring的async注解

    这里讨论一下getAsyncExecutor这里定义null的情况。 spring-context-4.3.9.RELEASE-sources.jar!/org...

    code4it
  • 【5分钟玩转Lighthouse】搭建bitwarden个人密码管理器

    现在各种网站和手机APP都要求设置密码和输入密码,每个人都要设置大量的密码。如果都设为统一密码,就存在一旦一个密码被攻破,其他密码都失效的情况。如果要分别设置为...

    风之泪
  • springboot之线程池ThreadPoolTaskExecutor以及@Async异步注解

    最近项目当中有需求,要进行异步的处理,需要使用到线程池,很久没有使用到线程池了,一来是做JAVAweb开发基本上很少用到异步处理,二来是发现有的老项目里面,线程...

    海加尔金鹰
  • SpringBoot中Async异步方法和定时任务介绍

    代码改变世界-coding
  • 【玩转SpringBoot】异步任务执行与其线程池配置

    同步代码写起来简单,但就是怕遇到耗时操作,会影响效率和吞吐量。 此时异步代码才是王者,但涉及多线程和线程池,以及异步结果的获取,写起来颇为麻烦。 不过在遇到...

    Java3y

扫码关注云+社区

领取腾讯云代金券