| 开关 | hive.exec.dynamic.partition |
|---|---|
| 模式 | nonstrict |
| 限制 | max.dynamic.partitions |
| 风险 | 分区爆炸 |
动态分区写入
动态分区写入
set hive.exec.dynamic.partition=true;
set hive.exec.dynamic.partition.mode=nonstrict;
set hive.exec.max.dynamic.partitions=2000;
INSERT OVERWRITE TABLE dwd_trade_order_di PARTITION (dt)
SELECT order_id, pay_amt, dt
FROM stg_order;动态分区列必须是 SELECT 的最后若干列，顺序错位会把数据写进错误分区。