Jacky Lau created FLINK-34702:
---------------------------------
Summary: Rank should not convert to StreamExecDuplicate when the
input is not insert only
Key: FLINK-34702
URL: https://issues.apache.org/jira/browse/FLINK-34702
Project: Flink
Issue Type: Bug
Components: Table SQL / Planner
Affects Versions: 1.20.0
Reporter: Jacky Lau
Fix For: 1.20.0
{code:java}
@Test
def testSimpleFirstRowOnBuiltinProctime1(): Unit = {
val sqlQuery =
"""
|SELECT *
|FROM (
| SELECT *,
| ROW_NUMBER() OVER (PARTITION BY a ORDER BY PROCTIME() ASC) as rowNum
| FROM (select a, count(b) as b from MyTable group by a)
|)
|WHERE rowNum = 1
""".stripMargin
util.verifyExecPlan(sqlQuery)
} {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
