| 前置检查 | 任务状态+分区锁 |
|---|---|
| 并发 | 同分区互斥 |
| 机制 | 调度队列串行 |
| 记录 | 重跑原因 |
状态探查
状态探查
-- 写入前确认目标分区是否已被并发任务占用（查询分区修改时间）
SHOW PARTITIONS dws_trade_store_day PARTITION (dt='2026-10-12');两个任务并发写同一分区通常不报错但结果不确定，属于隐性数据事故。
重跑保护：并发与状态检查
重跑前检查任务状态与下游依赖，避免与正在运行的任务并发写同一分区；调度平台一般提供加锁与串行队列能力。
易错点
- 失败任务与重跑任务同时执行，产出半新半旧数据
数据来源与参考
- 阿里《大数据之路：阿里巴巴大数据实践》