| 手段 | 分区重写/先删后插 |
|---|---|
| 判断 | 重跑两次结果一致 |
| 避免 | 无去重追加 |
| 验证 | 重复执行对比 |
幂等写法
幂等写法
-- 先清理目标分区,再写入,重跑结果一致
ALTER TABLE dws_trade_store_day DROP IF EXISTS PARTITION (dt='2026-10-12');
INSERT INTO TABLE dws_trade_store_day PARTITION (dt='2026-10-12')
SELECT store_id, order_cnt, pay_amt FROM tmp_trade_store_day;用系统当前时间做分区或版本字段,重跑会写进不同分区,幂等被破坏。