当前位置: 首页 > news >正文

Spark集群架构解析:核心组件与Standalone、YARN模式深度对比(AM,Container,Driver,Executor)

一、核心组件定义与关系拆解

1. ApplicationMaster(AM)
  • 定义:YARN 框架中的应用管理器,每个应用程序(如 Spark 作业)对应一个 AM。
  • 职责
    • 向 YARN 的 ResourceManager 申请资源(Container)。
    • 管理分配到的 Container,启动 Executor 进程。
    • 监控任务执行状态,处理失败重试。
  • 与其他组件关系:在 YARN 模式下,AM 是 Spark 与 YARN 的桥梁,不直接参与 Spark 作业逻辑(除了 yarn-cluster 模式下启动 Driver)。
2. Driver
  • 定义:Spark 应用的主控进程,是 Spark 作业的执行入口。
  • 职责
    • 创建 SparkContext,解析用户代码(如 RDD 转换)。
    • 将作业分解为 Task,调度到 Executor 执行。
    • 监控 Task 进度,收集结果,处理错误。
  • 与其他组件关系:在 Standalone 和 YARN 模式中位置不同(见下文对比),是 Spark 作业的 “大脑”。
3. Executor
  • 定义:运行 Spark 任务的工作进程,每个 Executor 负责执行多个 Task。
  • 职责
    • 维护 Task 执行的线程池,执行 Driver 分配的 Task。
    • 缓存 RDD 数据,供 Task 复用。
    • 向 Driver 汇报任务状态和结果。
  • 与其他组件关系:依赖 Container 提供的资源运行,受 Driver 调度。
4. Container
  • 定义:YARN 中的资源抽象单位,封装 CPU、内存等资源。
  • 职责:为应用程序组件(如 AM、Executor)提供运行环境
  • 与其他组件关系:AM 向 YARN 申请 Container 来启动 Executor,Driver 和 Executor 在 Container 中运行(YARN 模式下)。

在 yarn-cluster 模式下:AM、Driver、Executor 各自占用独立的 Container,且 Container 是物理隔离的资源单元(包含实际分配的内存、CPU 等资源),并非逻辑概念每个 Container 对应一个真实运行的进程容器,由 YARN 的 ResourceManager 按物理资源标准分配。

其实上面这些概念AM,Container都是在Spark on Yarn集群模式下才有的,AM,Container这些概念是Hadoop中的,Spark通过Yarn分配资源,那就一定会存在,Spark Standalone没有,因为它是不依赖于外部框架的,而是用自身提供的

二、Standalone 与 YARN 模式的架构对比

1. Standalone 模式(Spark 原生集群管理器)
  • 架构图

  • 核心关系
    • Driver:由客户端启动,直接与 Master(集群管理器)和 Worker(工作节点)交互。
    • Executor:由 Worker 启动,运行在 Worker 节点上,受 Driver 调度。
    • 无 ApplicationMaster:Standalone 是 Spark 自研的资源管理框架,不依赖 YARN,因此没有 AM 组件。
    • 资源管理:Master 负责分配 Worker 节点的资源给 Driver,Driver 直接控制 Executor 的启动。
 Standalone 模式为什么没有 AM 和 Container?
  • AM 的替代者:Standalone 模式中,Master 节点承担资源调度角色(类似 YARN 的 ResourceManager),但没有 AM 这个中间层。
  • 资源分配单位差异
    • YARN 用 Container 封装资源;Standalone 直接向 Worker 节点申请 Executor 进程(每个 Executor 对应 Worker 节点的一组 CPU / 内存)。
  • 组件运行方式
    • Driver:由客户端启动,运行在客户端或 Worker 节点(取决于--deploy-mode)。
    • Executor:由 Worker 节点直接启动,作为独立进程运行(无 Container 封装)。
Standalone 模式架构流程
Master(总调度)↓
Worker节点1↓
Driver(若deploy-mode=cluster)或Executor1↓
Worker节点2↓
Executor2、Executor3...
2. YARN 模式(Spark 运行在 YARN 集群上)
  • 架构图(以 yarn-cluster 为例)

  • 核心关系
    • ApplicationMaster:作为 YARN 与 Spark 的中间层,向 ResourceManager 申请 Container 资源,启动 Driver 和 Executor。
    • Driver

yarn-cluster 模式下由 AM 启动,运行在 Container 中;

yarn-client 模式下由客户端启动,运行在客户端机器。

  • Executor:运行在 NodeManager 管理的 Container 中,受 Driver 调度。
  • 资源管理:YARN 的 ResourceManager 统一管理集群资源,AM 作为应用代表申请资源,Driver 不直接与 ResourceManager 交互。
(1) yarn-cluster 模式:Container 是 “物理隔离的办公间”
  • Container 本质:YARN 分配的最小资源单元(内存 / CPU 等),是进程运行的物理容器(类似 Docker 容器)。
  • 组件与 Container 的映射
    • AM:单独占用 1 个 Container(由 ResourceManager 分配),负责启动 Driver 和申请 Executor 资源。
    • Driver:由 AM 在另一个 Container 中启动(属于 AM 的子任务)。
    • Executor:每个 Executor 占用 1 个 Container,由 AM 向 ResourceManager 申请后启动。
  • 类比场景
    • ResourceManager 是 “房东”,负责分配房间(Container);
    • AM 是 “租客代表”,租到第一个房间后,再替 Driver 和 Executor 租其他房间。
yarn-cluster 模式架构流程
ResourceManager(总房东)↓
AM(租客代表)[Container1]↓
Driver(项目经理)[Container2]↓
Executor1[Container3]、Executor2[Container4]...(工人)
(2) yarn-client 模式:Driver 跳出 Container 的 “例外”
  • Container 的角色
    • AM 占用 1 个 Container(在集群内),仅负责申请 Executor 的 Container。
    • 每个 Executor 占用 1 个 Container(在集群内)。
  • Driver 的特殊性
    • Driver 在客户端机器(非集群节点)直接运行,不依赖 Container(因为 YARN 无法管理客户端资源)。
    • 类比:AM 在集群内租房间给 Executor,但 Driver 在 “集群外的自家房子” 办公,只通过网络指挥集群内的 Executor。
yarn-client 模式架构流程
客户端机器(本地)↓
Driver(项目经理)[非Container]↓
ResourceManager(总房东)↓
AM(租客代表)[Container1]↓
Executor1[Container2]、Executor2[Container3]...(工人)

涉及ResourceManager,NodeManager的,从略微更高的角度,去理解以上他们之间关系,请见文章

YARN与Spark组件架构关系及交互机制:从ResourceManager到Executor的层级、依赖与通信链路解析-CSDN博客

三、两种模式下组件关系的类比理解

1. Standalone 模式:自营小团队
  • Master:团队领导,分配任务给 Worker(员工)。
  • Driver:项目经理,直接对接领导,安排具体工作(Task)给员工(Executor)。
  • Executor:员工,在自己的工位(Worker 节点)上干活,听项目经理指挥。
  • 特点:Spark 自己管资源,简单直接,但扩展性和资源隔离性较差。
2. YARN 模式:外包大公司
  • YARN ResourceManager:大公司 CEO,掌管所有资源(Container)。
  • ApplicationMaster:外包项目负责人,向 CEO 申请资源(Container),拿到资源后组建团队。
  • Driver:项目技术负责人,由外包负责人招聘(启动),负责具体技术方案和任务分配。
  • Executor:外包员工,在公司分配的工位(Container)上干活,听技术负责人指挥。
  • 特点:YARN 统一管资源,Spark 作为应用运行,适合多应用混部,资源利用率高。

四、关键差异总结表

对比维度Standalone 模式YARN 模式
资源管理器Spark 自研的 Master-Worker 架构YARN 的 ResourceManager-NodeManager 架构
ApplicationMaster无,Driver 直接与 Master 交互有,作为 Spark 应用与 YARN 的中间层
Driver 位置由客户端启动,运行在客户端或 Worker 节点yarn-client 在客户端,yarn-cluster 在集群内
Executor 运行环境直接运行在 Worker 节点上运行在 YARN 的 Container 中(资源隔离性更好)
适用场景小规模集群,Spark 单一应用场景大规模集群,多应用混部(如 Hadoop 生态)

五、一句话理清组件关系

  • Standalone:Driver(项目经理)直接找 Master(领导)要资源,分配给 Worker 上的 Executor(员工)干活。
  • YARN:AM(外包负责人)先找 YARN CEO(ResourceManager)要 Container(工位),用 Container 启动 Driver(技术负责人)和 Executor(员工),Driver 再指挥 Executor 干活。

相关文章:

  • Vue-创建应用/挂载应用/根组件模版-.vue单文件/应用配置
  • 上升沿计数 stm32 中断
  • 【R语言科研绘图】
  • python操作mysql数据库
  • R基于逻辑回归模型实现心脏病检测及SHAP值解释项目实战
  • Starrocks 怎么计算各个算子的统计信息
  • R语言科研编程-柱状图
  • DeepSeek 赋能医疗影像分析:从卷积神经网络到临床诊断效率革新
  • Spark 中,map和foreach的区别
  • 基于Spring boot+vue的中医养生系统的设计与实现(源码+论文+部署+安装+调试+售后)
  • STM32之看门狗(IWDG)
  • [CSS3]Flex布局
  • John the Ripper 入门指南:密码破解工具的正确打开方式
  • Cmake编译gflags过程记录和在QT中测试
  • Qt实战:自定义QTreeWidget搜索隐藏显示项功能 | 附完整源码
  • 轻量化开源方案——浅析PdfPatcher实际应用
  • 在单片机中如何在断电前将数据保存至DataFlash?
  • C++:整数奇偶排序
  • [特殊字符] 使用增量同步+MQ机制将用户数据同步到Elasticsearch
  • MATLAB 2023b 配电柜温度报警系统仿真
  • 网站名称及网址/南昌seo实用技巧
  • 广州市品牌网站建设企业/汽车品牌推广策划方案
  • wordpress app 生成6/如何优化关键词的排名
  • 永久免费网站空间/电商关键词工具
  • 厦门做新零售直销网站公司app/广州市新闻最新消息
  • 网站url 结构/汕头seo建站