Matthias Pohl created FLINK-30828:
-------------------------------------
Summary: SortAggITCase.testLeadLag failed
Key: FLINK-30828
URL: https://issues.apache.org/jira/browse/FLINK-30828
Project: Flink
Issue Type: Bug
Components: Table SQL / Planner
Affects Versions: 1.17.0
Reporter: Matthias Pohl
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=45389&view=logs&j=0c940707-2659-5648-cbe6-a1ad63045f0a&t=075c2716-8010-5565-fe08-3c4bb45824a4&l=12560
{code}
Jan 30 11:03:32 [ERROR] Tests run: 72, Failures: 1, Errors: 0, Skipped: 0, Time
elapsed: 37.42 s <<< FAILURE! - in
org.apache.flink.table.planner.runtime.batch.sql.agg.SortAggITCase
Jan 30 11:03:32 [ERROR]
org.apache.flink.table.planner.runtime.batch.sql.agg.SortAggITCase.testLeadLag
Time elapsed: 0.547 s <<< FAILURE!
Jan 30 11:03:32 java.lang.AssertionError:
Jan 30 11:03:32
Jan 30 11:03:32 Results do not match for query:
Jan 30 11:03:32
Jan 30 11:03:32 SELECT
Jan 30 11:03:32 a,
Jan 30 11:03:32 b, LEAD(b, 1) over (order by a) AS bLead, LAG(b, 1) over
(order by a) AS bLag,
Jan 30 11:03:32 c, LEAD(c, 1) over (order by a) AS cLead, LAG(c, 1) over
(order by a) AS cLag,
Jan 30 11:03:32 d, LEAD(d, 1) over (order by a) AS dLead, LAG(d, 1) over
(order by a) AS dLag,
Jan 30 11:03:32 e, LEAD(e, 1) over (order by a) AS eLead, LAG(e, 1) over
(order by a) AS eLag,
Jan 30 11:03:32 f, LEAD(f, 1) over (order by a) AS fLead, LAG(f, 1) over
(order by a) AS fLag,
Jan 30 11:03:32 g, LEAD(g, 1) over (order by a) AS gLead, LAG(g, 1) over
(order by a) AS gLag,
Jan 30 11:03:32 h, LEAD(h, 1) over (order by a) AS hLead, LAG(h, 1) over
(order by a) AS hLag,
Jan 30 11:03:32 i, LEAD(i, 1) over (order by a) AS iLead, LAG(i, 1) over
(order by a) AS iLag,
Jan 30 11:03:32 j, LEAD(j, 1) over (order by a) AS jLead, LAG(j, 1) over
(order by a) AS jLag,
Jan 30 11:03:32 k, LEAD(k, 1) over (order by a) AS kLead, LAG(k, 1) over
(order by a) AS kLag,
Jan 30 11:03:32 l, LEAD(l, 1) over (order by a) AS lLead, LAG(l, 1) over
(order by a) AS lLag,
Jan 30 11:03:32 m, LEAD(m, 1) over (order by a) AS mLead, LAG(m, 1) over
(order by a) AS mLag,
Jan 30 11:03:32 n, LEAD(n, 1) over (order by a) AS nLead, LAG(n, 1) over
(order by a) AS nLag
Jan 30 11:03:32
Jan 30 11:03:32 FROM UnnamedTable$230
Jan 30 11:03:32 order by a
Jan 30 11:03:32
Jan 30 11:03:32
Jan 30 11:03:32 Results
Jan 30 11:03:32 == Correct Result - 3 ==
== Actual Result - 3 ==
Jan 30 11:03:32 +I[Alice, 1, 1, null, 1, 1, null, 2, 2, null, 9223, 9223,
null, -2.3, -2.3, null, 9.9, 9.9, null, true, true, null, varchar, varchar,
null, char , char , null, 2021-08-03, 2021-08-03,
null, 20:08:17, 20:08:17, null, 2021-08-03T20:08:29, 2021-08-03T20:08:29, null,
9.99, 9.99, null] +I[Alice, 1, 1, null, 1, 1, null, 2, 2, null, 9223, 9223,
null, -2.3, -2.3, null, 9.9, 9.9, null, true, true, null, varchar, varchar,
null, char , char , null, 2021-08-03, 2021-08-03,
null, 20:08:17, 20:08:17, null, 2021-08-03T20:08:29, 2021-08-03T20:08:29, null,
9.99, 9.99, null]
Jan 30 11:03:32 +I[Alice, 1, null, 1, 1, null, 1, 2, null, 2, 9223, null,
9223, -2.3, null, -2.3, 9.9, null, 9.9, true, null, true, varchar, null,
varchar, char , null, char , 2021-08-03, null,
2021-08-03, 20:08:17, null, 20:08:17, 2021-08-03T20:08:29, null,
2021-08-03T20:08:29, 9.99, null, 9.99] +I[Alice, 1, null, 1, 1, null, 1, 2,
null, 2, 9223, null, 9223, -2.3, null, -2.3, 9.9, null, 9.9, true, null, true,
varchar, null, varchar, char , null, char ,
2021-08-03, null, 2021-08-03, 20:08:17, null, 20:08:17, 2021-08-03T20:08:29,
null, 2021-08-03T20:08:29, 9.99, null, 9.99]
Jan 30 11:03:32 !+I[Alice, null, null, 1, null, null, 1, null, null, 2, null,
null, 9223, null, null, -2.3, null, null, 9.9, null, null, true, null, null,
varchar, null, null, char , null, null, 2021-08-03, null, null,
20:08:17, null, null, 2021-08-03T20:08:29, null, null, 9.99]
+I[Alice, null, 1, null, null, 1, null, null, 2, null, null,
9223, null, null, -2.3, null, null, 9.9, null, null, true, null, null, varchar,
null, null, char , null, null, 2021-08-03, null, null, 20:08:17,
null, null, 2021-08-03T20:08:29, null, null, 9.99, null]
Jan 30 11:03:32
Jan 30 11:03:32 Plan:
Jan 30 11:03:32 == Abstract Syntax Tree ==
Jan 30 11:03:32 LogicalSort(sort0=[$0], dir0=[ASC-nulls-first])
Jan 30 11:03:32 +- LogicalProject(inputs=[0..1], exprs=[[LEAD($1, 1) OVER
(ORDER BY $0 NULLS FIRST), LAG($1, 1) OVER (ORDER BY $0 NULLS FIRST), $2,
LEAD($2, 1) OVER (ORDER BY $0 NULLS FIRST), LAG($2, 1) OVER (ORDER BY $0 NULLS
FIRST), $3, LEAD($3, 1) OVER (ORDER BY $0 NULLS FIRST), LAG($3, 1) OVER (ORDER
BY $0 NULLS FIRST), $4, LEAD($4, 1) OVER (ORDER BY $0 NULLS FIRST), LAG($4, 1)
OVER (ORDER BY $0 NULLS FIRST), $5, LEAD($5, 1) OVER (ORDER BY $0 NULLS FIRST),
LAG($5, 1) OVER (ORDER BY $0 NULLS FIRST), $6, LEAD($6, 1) OVER (ORDER BY $0
NULLS FIRST), LAG($6, 1) OVER (ORDER BY $0 NULLS FIRST), $7, LEAD($7, 1) OVER
(ORDER BY $0 NULLS FIRST), LAG($7, 1) OVER (ORDER BY $0 NULLS FIRST), $8,
LEAD($8, 1) OVER (ORDER BY $0 NULLS FIRST), LAG($8, 1) OVER (ORDER BY $0 NULLS
FIRST), $9, LEAD($9, 1) OVER (ORDER BY $0 NULLS FIRST), LAG($9, 1) OVER (ORDER
BY $0 NULLS FIRST), $10, LEAD($10, 1) OVER (ORDER BY $0 NULLS FIRST), LAG($10,
1) OVER (ORDER BY $0 NULLS FIRST), $11, LEAD($11, 1) OVER (ORDER BY $0 NULLS
FIRST), LAG($11, 1) OVER (ORDER BY $0 NULLS FIRST), $12, LEAD($12, 1) OVER
(ORDER BY $0 NULLS FIRST), LAG($12, 1) OVER (ORDER BY $0 NULLS FIRST), $13,
LEAD($13, 1) OVER (ORDER BY $0 NULLS FIRST), LAG($13, 1) OVER (ORDER BY $0
NULLS FIRST)]])
Jan 30 11:03:32 +- LogicalUnion(all=[true])
[...]
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
