专栏首页Flink-selfLearnFlink启动-13.TaskExecutor向RM注册自己
原创

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

13. taskExecutor向Rm注册自己

DONE:

1. RM在启动的时候是如何通过HAService暴露自己的和注册自己的

2. TaskExecutor在接收到RM的变动后, 会向RM注册自己.

TODO

1. 第5步下半部分: resourceManager向TM申请slot.

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

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

我来说两句

0 条评论
登录 后参与评论

相关文章

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

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

    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源码分析之TaskManager启动篇

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

    开发架构二三事
  • 聊聊flink的logback配置

    flink-release-1.7.1/flink-dist/src/main/flink-bin/bin/flink-daemon.sh

    code4it
  • 聊聊flink的logback配置

    flink-release-1.7.1/flink-dist/src/main/flink-bin/bin/flink-daemon.sh

    code4it
  • [源码解析] Flink的Slot究竟是什么?(2)

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

    罗西的思考
  • Flink 在有赞实时计算的实践

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

    Fayson
  • www6669988com请拨18687679362_环球国际Flink源码走读(一):Flink工程目录

    导语 | Flink已经成为未来流计算趋势,目前在很多大厂已经有了大规模的使用。最近在学习Flink源码,就想把自己学习的过程分享出来,希望能帮助到志同道合的朋...

    用户7106032
  • Flink源码走读(一):Flink工程目录

    导语 | Flink已经成为未来流计算趋势,目前在很多大厂已经有了大规模的使用。最近在学习Flink源码,就想把自己学习的过程分享出来,希望能帮助到志同道合的朋...

    2011aad
  • 《从0到1学习Flink》—— Mac 上搭建 Flink 1.6.0 环境并构建运行简单程序入门

    2、在 Mac OS X 上安装 Flink 是非常方便的。推荐通过 homebrew 来安装。

    zhisheng
  • Flink部署及作业提交(On Flink Standalone)

    部署Flink之前首先需要安装好JDK,可以选择8或11版本,我这里选择的是JDK11:

    端碗吹水
  • 大数据开发:Flink on Yarn原理

    在流计算越来越受到重视的大趋势下,Flink框架受到的关注和重视,可以说是与日俱增,在大数据的学习当中,Flink也成为重要的一块。今天的大数据开发分享,我们主...

    成都加米谷大数据
  • Flink 1.7.0 安装、配置与使用

    Apache Flink是一个面向分布式数据流处理和批量数据处理的开源计算平台,它能够基于同一个Flink运行时,提供支持流处理和批处理两种类型应用的功能。

    用户1205080
  • 一文读懂Apache Flink架构及特性分析。

    Flink是个相当早的项目,开始于2008年,但只在最近才得到注意。Flink是原生的流处理系统,提供high level的API。Flink也提供 API来像...

    搜云库技术团队
  • Flink集群部署

    上一节我们讲了单机模式如何部署启动,这节我们基于CentOS 7虚拟机搭建一个3个节点的集群:

    王知无-import_bigdata
  • Flink入门:读取Kafka实时数据流,实现WordCount

    本文主要介绍Flink接收一个Kafka文本数据流,进行WordCount词频统计,然后输出到标准输出上。通过本文你可以了解如何编写和运行Flink程序。

    PP鲁

扫码关注云+社区

领取腾讯云代金券