OOM（Out of Memory） 是指程序运行过程中内存不足的情况。在 Spark 应用程序中，OOM 是一个非常常见的问题，尤其是在处理大规模数据集或执行资源密集型的操作时。当 Spark 作业尝试使用的内存超过了为其分配的内存限制时，就会发生 OOM 错误。
Spark 中的 OOM 错误可能发生在多个层面：
- Executor OOM：
- 当单个 Executor 进程中的某个任务尝试使用的堆内存超过了为其配置的 JVM 堆内存限制时，会发生 Executor OOM。这通常是由于数据倾斜（某个 key 的数据量特别大）或任务逻辑本身内存消耗较高导致的。
- 解决方法包括：增加 Executor 的内存配置、优化数据倾斜问题、减少缓存数据量、调整并行度等。
- Driver OOM：
- Driver 进程也可能遇到内存不足的情况，尤其是在执行复杂的逻辑或收集大量小对象到 Driver 端时。
- 解决方法包括：增加 Driver 的内存配置、优化 Driver 端逻辑、减少从 Executor 端收集的数据量等。
- Off-Heap Memory OOM：
- Spark 还使用了堆外内存（Off-Heap Memory）来存储一些数据结构，如缓存的广播变量和某些数据结构。当这些堆外内存使用超过配置的限制时，也会发生 OOM。
- 解决方法包括：增加堆外内存的配置、检查并优化广播变量和数据结构的使用等。
解决 OOM 问题通常需要综合多种策略：
- 资源调整：增加 Executor 的内存、CPU 核数以及 Driver 的内存配置。
- 优化代码：减少不必要的内存使用，例如避免使用大的 Shuffled Datasets，优化数据结构和算法以减少内存占用。
- 数据倾斜处理：使用
repartition、salting技术或自定义分区策略来处理数据倾斜。- GC（Garbage Collection）调优：调整 JVM 的垃圾回收策略，例如使用 G1GC 替代 CMS GC。
- 监控和日志分析：使用 Spark UI、Yarn UI 等工具监控资源使用情况，分析日志找出具体的 OOM 发生位置和原因。
在 Spark 应用程序中处理 OOM 问题时，通常需要进行多次迭代和优化，结合应用程序的具体逻辑和数据特性，逐步找到最优的解决方案