Flink-源码学习-架构设计-部署模式-Session-Flink On Kubernetes
正在总结中,等我😭~~~
Flink-源码学习-架构设计-部署模式-Session-Flink On Standalone
正在总结中,等我😭~~~
Flink-源码学习-架构设计-部署模式-Session-Flink On Kubernetes
正在总结中,等我😭~~~
Flink-源码学习-集群启动-standalone
一、概述Flink 采用 Master-Slave 架构,其中 JobManager 作为集群 Master 节点,主要负责任务协调和资源分配,TaskManager 作为 slave 节点,用于执行任务。
二、集群启动脚本Flink 集群的启动脚本在 flink-dist 子项目中,位于 flink-bin 下的 bin 目录,启动脚本为: startcluster.sh
该脚本会首先调用 config.sh 分别从 conf/masters 和 conf/workers 配置文件中获取 masters 和 workers 信息,然后分别:
通过 jobmanager.sh 启动 JobManager
通过 taskmanager.sh 启动 TaskManager
他们的内部,都通过 flink-daemon.sh 脚本来启动 JVM 进程,分析 flink-daemon.sh 脚本发现:
JobManager 的启动代号: standalonesession,启动主类 StandaloneSessionClusterEntrypoint
123(stand ...
Flink-源码学习-架构设计-部署模式-Application-Flink On Yarn
正在总结中,等我😭~~~
Flink-源码学习-架构设计-部署模式-PerJob-Flink On Yarn
正在总结中,等我😭~~~
Flink-源码学习-架构设计-部署模式-Application-Flink On Yarn
正在总结中,等我😭~~~
Flink-源码学习-架构设计-部署模式-PerJob-Flink On Yarn
正在总结中,等我😭~~~