jnh5y commented on code in PR #25206:
URL: https://github.com/apache/flink/pull/25206#discussion_r1857690306
##########
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/RankTestPrograms.java:
##########
@@ -184,4 +207,32 @@ private static TableTestProgram getTableTestProgram(
+ "(select a, b, row_number()
over(partition by a order by t asc) as c from MyTable1)"
+ " where c <= 2")
.build();
+
+ public static final TableTestProgram RANK_2_TEST =
Review Comment:
As a note, this test is not supported in batch execution mode. An error
`Table RANK() on streaming table is not supported currently` is returned.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
