1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
2
3
4
5
6
7
8
9
10
11
12
13
14
15
INSERT OVERWRITE TABLE dw_layer.dwd_produce_order
PARTITION(dt = '2026-03-28')
SELECT
order_id,
produce_code,
material_id,
qty,
CASE WHEN status = 1 THEN 'RUNNING' ELSE 'FINISHED' END AS status_name,
start_time,
end_time
FROM ods_layer.ods_mom_produce_order_di
WHERE dt = '2026-03-28'
AND qty > 0;
-- 校验逻辑：判断物料是否存在于基础表
SELECT count(1) FROM dw_layer.dwd_material_info;
PARTITION(dt = '2026-03-28')
SELECT
order_id,
produce_code,
material_id,
qty,
CASE WHEN status = 1 THEN 'RUNNING' ELSE 'FINISHED' END AS status_name,
start_time,
end_time
FROM ods_layer.ods_mom_produce_order_di
WHERE dt = '2026-03-28'
AND qty > 0;
-- 校验逻辑：判断物料是否存在于基础表
SELECT count(1) FROM dw_layer.dwd_material_info;
执行结果
运行日志 (12)
调度参数
版本对比
[SUCCESS]
2026-03-28 10:15:32
任务提交成功, JobID: application_171162483244_001
| order_id | produce_code | status_name | qty |
|---|---|---|---|
| ORD-20260328-001 | PC-7721 | RUNNING | 1,500.00 |
| ORD-20260328-002 | PC-8842 | FINISHED | 2,200.00 |
| ORD-20260328-003 | PC-1250 | RUNNING | 450.00 |
显示前 3 条结果，共计影响 1,280 行数据。