From aceeac91d4f46f834ceab78a59d4d51b19ac768f Mon Sep 17 00:00:00 2001 From: Adarsh Sanjeev Date: Wed, 22 Feb 2023 21:44:46 +0530 Subject: [PATCH] Fix MSQ IT test (#13808) --- .../multi-stage-query/wikipedia_merge_index_msq.sql | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/integration-tests-ex/cases/src/test/resources/multi-stage-query/wikipedia_merge_index_msq.sql b/integration-tests-ex/cases/src/test/resources/multi-stage-query/wikipedia_merge_index_msq.sql index 1e04e38436b..6ebd5ac3f2f 100644 --- a/integration-tests-ex/cases/src/test/resources/multi-stage-query/wikipedia_merge_index_msq.sql +++ b/integration-tests-ex/cases/src/test/resources/multi-stage-query/wikipedia_merge_index_msq.sql @@ -13,8 +13,11 @@ SELECT SUM("added") AS "added", SUM("deleted") AS "deleted", SUM("delta") AS "delta", - EARLIEST("user", 128) AS "first_user", - LATEST("user", 128) AS "last_user" +-- Disabled due to https://github.com/apache/druid/issues/13824. To be reverted once issue is resolved. +-- EARLIEST("user", 128) AS "first_user", +-- LATEST("user", 128) AS "last_user" + EARLIEST_BY("user", CASE WHEN CAST("timestamp" AS BIGINT) > 0 THEN MILLIS_TO_TIMESTAMP(CAST("timestamp" AS BIGINT)) ELSE TIME_PARSE("timestamp") END, 128) AS "first_user", + LATEST_BY("user", CASE WHEN CAST("timestamp" AS BIGINT) > 0 THEN MILLIS_TO_TIMESTAMP(CAST("timestamp" AS BIGINT)) ELSE TIME_PARSE("timestamp") END, 128) AS "last_user" FROM "source" GROUP BY 1, 2 PARTITIONED BY DAY \ No newline at end of file