Flink1.15源码解析

Posted 宝哥大数据

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Flink1.15源码解析相关的知识,希望对你有一定的参考价值。

本文基于flink-1.15源码

0、基础概念

   Flink1.15源码解析–安全模块及安全上下文

一、任务提交流程

 1.0、start-cluster.sh 启动集群

  启动JobManager
   ClusterEntrypoint
   DispatcherResourceManagerComponent
    WebMonitorEndpoint
    ResourceManager
    Dispatcher

  启动TaskManager

 1.1、flink run

 1.2、yarn-session.sh

二、通讯过程

三、Task调度

四、内存模型

待续。。。

参考:
https://blog.csdn.net/EdwardWong_/article/details/126532322
https://blog.csdn.net/qq_24095055/article/details/124600378

以上是关于Flink1.15源码解析的主要内容,如果未能解决你的问题,请参考以下文章

Flink1.15源码解析--启动JobManager

Flink1.15源码解析--启动JobManager----ResourceManager启动

Flink1.15源码解析--启动JobManager----ResourceManager启动

Flink1.15源码解析--启动JobManager----Dispatcher启动

Flink1.15源码解析--启动JobManager----Dispatcher启动

Flink1.15源码解析--选举