Zoltan Haindrich created HIVE-24963: ---------------------------------------
Summary: Windowing expression may loose its input in some cases Key: HIVE-24963 URL: https://issues.apache.org/jira/browse/HIVE-24963 Project: Hive Issue Type: Bug Reporter: Zoltan Haindrich Assignee: Zoltan Haindrich {code} drop table if exists sss; CREATE TABLE `sss`( `user_id` bigint, `user_mid` string ) PARTITIONED BY ( `dt` string) STORED AS ORC ; insert into sss partition(dt='part1') VALUES (12345,'user_mid v1'),(12345,'user_mid v1'),(12345,'user_mid v1'),(12345,'user_mid v1'),(12345,'user_mid v1'); set hive.auto.convert.join.noconditionaltask.size=1; WITH unioned_user AS ( SELECT *, row_number() OVER (PARTITION BY user_mid ORDER BY dt ASC) AS r_asc, row_number() OVER (PARTITION BY user_mid ORDER BY dt DESC) AS r_desc FROM ( SELECT DISTINCT dt, user_mid FROM sss WHERE dt = '20210228' UNION ALL SELECT DISTINCT dt, user_mid FROM sss ) AS uni ), merged_user AS ( SELECT a.user_mid FROM (SELECT * FROM unioned_user WHERE r_asc = 1) AS a INNER JOIN (SELECT * FROM unioned_user WHERE r_desc = 1) AS d ON a.user_mid = d.user_mid ) Select count(*) from merged_user; {cdode} -- This message was sent by Atlassian Jira (v8.3.4#803005)