Flink1.15源码解析
Posted 宝哥大数据
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Flink1.15源码解析相关的知识,希望对你有一定的参考价值。
本文基于flink-1.15
源码
0、基础概念
一、任务提交流程
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----ResourceManager启动
Flink1.15源码解析--启动JobManager----ResourceManager启动
Flink1.15源码解析--启动JobManager----Dispatcher启动