问题一: session模式,哪些组件是共用的?
问题二:每种模式的优缺点
问题三: runtime有哪些组件构成?
问题四: JobManager有哪些组件?
runtime summary
https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=65147077
JobManager

Dispatcher
提供Client的RPC接口
ResourceManager
与Yarn resource manager不同,用来管理Flink的TaskManager资源
JobMaster
一个任务的生命周期,每个Flink job各有一个JobMaster与之对应
Web server
TaskManager
TaskManager 其实功能比较简单,提供一些基本的 RPC 服务,供 JobManager 进行调度
集群启动
per-job mode
yarn session mode
application mode
参考文献
- flink on yarn 远程 debug 提交流程源码分析看不懂?看完这53张图包你学会!
- Flink on yarn per-job的架构、提交流程和代码分析
- 如何开启远程调试,本地调试
- Flink是如何工作的?
- Flink启动顺序,各个组件启动流程
- 详解Flink作业提交流程
- Session模式、Per-job模式、K8s session模式提交流程
- 剖析Flink运行时的整体架构
- 各个组件的作用
- Apache Flink on Kubernetes: 四种模式,我该选择哪种?
- Apache Flink进阶(一):Runtime核心机制