Я решил проблему, разделив запрос на 2 части:
create table if not exists table_a (
code int,
md varchar(150),
name varchar(150),
region varchar(50),
dingestdate timestamp,
dingestdate_latest timestamp
)
row format delimited fields terminated by '|'
stored as parquet
tblproperties("parquet.compression"="gzip")
;
и
insert overwrite table table_a
select * from (
select
code,
md,
name,
region,
dingestdate,
max(dingestdate) over (partition by code) as dingestdate_latest
from table1 ) as test1 where dingestdate = dingestdate_latest
;
и, наконец, запрос в SSIS выполняется без ошибок.
Я также попробую «Выполнить задачу процесса» в SSIS, чтобы проверить, работает ли она.
Спасибо.