Jingsong Lee created FLINK-23107: ------------------------------------ Summary: Separate deduplicate rank from rank functions Key: FLINK-23107 URL: https://issues.apache.org/jira/browse/FLINK-23107 Project: Flink Issue Type: Improvement Components: Table SQL / Runtime Reporter: Jingsong Lee Fix For: 1.14.0
SELECT * FROM (SELECT *, ROW_NUMBER() OVER (PARTITION BY d ORDER BY e DESC) AS rownum from T) WHERE rownum=1 Actually above sql is a deduplicate rank instead of a normal rank. We should separate the implementation for optimize the deduplicate rank and reduce bugs. -- This message was sent by Atlassian Jira (v8.3.4#803005)