AQE（Adaptive Query Execution，自适应查询执行） 是 sparksql 的一种动态优化机制，当开启 aqe 后，每当 shuffle map 阶段执行完毕，aqe 都会结合这个阶段 shuffle map 输出的中间文件的统计信息，基于既定的规则动态调整逻辑和物理执行计划，来完成运行时的优化* shuffle map / reduce 阶段 同 shuffle write / readaqe 默认是关闭（从 spark 3.2 开始默认开启），通过下面这个参数开启 # 开启 AQE set spark.sql.adaptive.enabled = true; AQE既...