2014 年，Spark 在 Daytona GraySort 基准测试中以 1/10 的机器数量、3 倍的速度 击败 Hadoop MapReduce，一举终结了 MR 的黄金时代。本文从演变历史、架构设计、Shuffle 机制三个维度深度对比 Spark 与 MapReduce，帮你理解这场代际更替的本质。
一、Spark 演变历史：从伯克利实验室到 Apache 顶级项目
Spark 的诞生源于一个朴素的问题：MapReduce 做迭代计算为什么这么慢？
2009 — 诞生：伯克利 AMPLab
Matei Zaharia 在 UC Berkeley AMPLab 启动 Spark 项目。最初的动机非常具体——机器学习算法需要反复迭代同一份数据，而 Hadoop MapReduce 每轮迭代都要把中间结果写回 HDFS，磁盘 I/O 成为不可逾越的瓶颈。Spark 的核心想法是：把中间结果留在内存里。
2010 — 开源：BSD 协议发布
Spark 以 BSD 协议在 GitHub 开源。同年，RDD（Resilient Distributed Dataset） 论文发表（NSDI 2012 最佳论文），奠定了 Spark 的理论基础。RDD 通过 Lineage 血统机制实现容错，避免了 MR 的数据复制开销。
2013 — 进入 Apache 孵化器
Spark 进入 Apache 孵化器，社区快速扩张。同年发布了 Spark SQL（Shark → Spark SQL 1.0） 和 Spark Streaming，生态开始成型。Databricks 公司成立，由项目创始人 Matei Zaharia 联合创办。
2014 — 顶级项目 + 破纪录
Spark 毕业成为 Apache 顶级项目。在 Daytona GraySort 100TB 排序基准测试中，Spark 使用 206 个节点在 23 分钟 完成排序，而 Hadoop MR 传统记录需要 2100 个节点在 72 分钟 完成——性价比提升 30 倍以上。同年发布 Spark 1.0，新增 MLlib 机器学习库。
2016 — Spark 2.0：统一化时代
Spark 2.0 发布，引入 Structured Streaming、DataFrame/DataSet 统一 API、Whole-Stage Code Generation。Tungsten 执行引擎的第二阶段使得物理执行性能接近手写 C 代码。从此，Spark 不再是 "MR 的替代品"，而是一个完整的大数据操作系统。
从 2009 年实验室孵化到 2016 年 Spark 2.0，Spark 用 7 年走完了 MapReduce 14 年的路，并 在几乎所有维度上超越了它。
二、架构对比：MapReduce vs Spark
理解两代计算引擎的差异，首先要看懂它们的进程模型：
MapReduce — 进程级、两阶段、磁盘驱动
MapReduce 的每个 Task 运行在独立的 JVM 进程中。每轮 MapReduce 作业执行完毕后，所有进程销毁，中间结果强制写回 HDFS。下一轮作业再从 HDFS 读取——这就是"迭代计算慢"的根源。
· JobTracker / TaskTracker（1.x）或 ResourceManager / NodeManager（2.x YARN）负责调度
· Map → Shuffle&Sort → Reduce 固定三阶段，无 DAG 优化
· 每个 Task 是独立 JVM 进程，启动开销大
· 中间结果必须序列化到磁盘
Spark — 线程级、DAG 驱动、内存优先
Spark 的Executor JVM 常驻，Task 以线程形式运行。DAGScheduler 将整个作业转换为 Stage 图，窄依赖 Stage 内部数据通过内存 Pipeline 传递，只有 Shuffle 边界才需要落盘。
· Driver + Executor 常驻进程，Task 以线程运行
· DAG 优化：全局视角消除冗余计算，Pipeline 窄依赖链路
· 内存优先：RDD 缓存 + 中间结果内存传递
· Lazy Evaluation：只在 Action 时触发计算，可以全局优化
三、Shuffle 对比：三次落盘 vs 一次落盘
Shuffle 是分布式计算中最昂贵的环节。MapReduce 和 Spark 在 Shuffle 设计上的差异，是两者性能鸿沟的核心原因之一：
MapReduce Shuffle：三次磁盘 I/O
① Map 输出 → 写入环形缓冲区 → 溢出到本地磁盘（第一次落盘）
② 归并排序后 → 再次写入本地磁盘（第二次落盘）
③ Reduce 端拉取后 → 归并排序 → 写入本地磁盘（第三次落盘）→ 读取给 reduce() 函数
Spark Shuffle：一次落盘 + 内存传输
① Map 端排序后 → 写入本地磁盘 index+data 文件（唯一落盘）
② Reduce 端拉取 → 直接进入内存，排序后计算
③ 窄依赖场景（map/filter）→ 完全不落盘，Pipeline 内存传输
Spark 在 窄依赖 Pipeline 中完全不触发 Shuffle，而 MR 每个 Map-Reduce 边界都强制执行一次完整的 Shuffle。这就是迭代计算场景下 Spark 比 MR 快 10-100 倍的根本原因。
四、性能差异的四大根源
1. 进程 vs 线程：MR 每个 Task 启动新 JVM（秒级开销），Spark Executor 常驻复用线程（毫秒级）。1000 个 Task，Spark 省去 1000 次 JVM 启动。
2. 中间结果存储：MR 强制写 HDFS（3 副本），Spark 优先内存 Pipeline + 有选择缓存。迭代计算 10 轮——MR 写入 30 份 HDFS 副本，Spark 只在内存中流转。
3. 执行模型：MR 固定 Map-Reduce 两阶段，多 Job 串联需手动编排。Spark 通过 DAG 自动优化全局执行计划，消除冗余 Shuffle 和重复计算。
4. 数据抽象：MR 的数据模型是 Key-Value 对，表达能力受限。Spark 的 RDD 支持丰富的 Transformation API（map/filter/join/cogroup 等），开发者可以写出更高效的逻辑。
五、技术选型：什么时候该用谁？
尽管 Spark 在多数场景下已经取代 MapReduce，但仍有各自的适用场景：
选用 Spark：
· 迭代计算（ML 训练、图计算）
· 交互式查询（Spark SQL + BI 工具）
· 流处理 + 批处理统一（Lambda 架构简化）
· 复杂多阶段 ETL Pipeline
MapReduce 仍有价值：
· 极大规模的离线批处理（PB 级以上，对延迟不敏感）
· 与 Hive 传统生态深度绑定的存量任务
· 资源极度受限的环境（每个 Task 独立进程更易隔离）
写在最后
Spark 的崛起不是偶然。它不是简单地"把 MR 内存化"，而是从进程模型、数据抽象、调度引擎到生态设计的全面重构。
理解 Spark 与 MapReduce 的差异，不只是背诵对比表格，而是要理解三个本质问题：进程 vs 线程的启动开销、中间结果存储的策略差异、DAG 全局优化 vs 固定两阶段。吃透了这三点，你就真正理解了分布式计算引擎的代际演进。
不是 Spark 赢了 MapReduce，是内存计算赢了磁盘计算。
