| 定位 | 统一批流引擎 |
|---|---|
| 兼容 | Hive Metastore/语法 |
| 优化 | Catalyst+钨丝计划 |
| 场景 | ETL/分析/流 |
Spark 提交作业
Spark 提交作业
spark-submit \
--master yarn \
--deploy-mode cluster \
--num-executors 20 --executor-memory 8g \
--conf spark.sql.shuffle.partitions=400 \
job_trade_dws.pySpark 3.x 的 AQE 与动态分区裁剪在多数 ETL 场景能减少手工调参。