bug fix
This commit is contained in:
@@ -135,7 +135,7 @@ from dwd.dwd_gnd_dept_pack_property
|
|||||||
-- create or replace table dm.dm_chc_pack_property
|
-- create or replace table dm.dm_chc_pack_property
|
||||||
-- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_chc_pack_property'
|
-- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_chc_pack_property'
|
||||||
-- as
|
-- as
|
||||||
-- insert overwrite table dm.dm_thc_pack_property
|
insert overwrite table dm.dm_thc_pack_property
|
||||||
WITH dedup_l AS (
|
WITH dedup_l AS (
|
||||||
SELECT *,
|
SELECT *,
|
||||||
ROW_NUMBER() OVER (PARTITION BY iqvia_pack_code ORDER BY iqvia_pack_code) AS rn
|
ROW_NUMBER() OVER (PARTITION BY iqvia_pack_code ORDER BY iqvia_pack_code) AS rn
|
||||||
@@ -228,4 +228,4 @@ SELECT
|
|||||||
from_utc_timestamp(current_timestamp(),'UTC+8') as ETL_UPDATE_DT
|
from_utc_timestamp(current_timestamp(),'UTC+8') as ETL_UPDATE_DT
|
||||||
FROM dedup_l l
|
FROM dedup_l l
|
||||||
LEFT JOIN dedup_r r
|
LEFT JOIN dedup_r r
|
||||||
ON l.iqvia_pack_code = r.PACK_COD
|
ON l.iqvia_pack_code = r.PACK_COD
|
||||||
|
|||||||
Reference in New Issue
Block a user