Apache/druid
1
0
Fork 0
mirror of https://github.com/apache/druid.git synced 2025-02-09 03:24:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix MSQ IT test (#13808)

Browse Source
This commit is contained in:
Adarsh Sanjeev 2023-02-22 21:44:46 +05:30 committed by GitHub
parent d2dbb8b2c0
commit aceeac91d4
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
integration-tests-ex/cases/src/test/resources/multi-stage-query/wikipedia_merge_index_msq.sql
View File

@ -13,8 +13,11 @@ SELECT
SUM("added") AS "added", SUM("added") AS "added",
SUM("deleted") AS "deleted", SUM("deleted") AS "deleted",
SUM("delta") AS "delta", SUM("delta") AS "delta",
EARLIEST("user", 128) AS "first_user", -- Disabled due to https://github.com/apache/druid/issues/13824. To be reverted once issue is resolved.
LATEST("user", 128) AS "last_user" -- 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" FROM "source"
GROUP BY 1, 2 GROUP BY 1, 2
PARTITIONED BY DAY PARTITIONED BY DAY