JinxinTang created CALCITE-4107:
-----------------------------------

             Summary: Flink need result of method `allowsFraming` in 
`org.apache.calcite.sql.SqlRankFunction` to be true
                 Key: CALCITE-4107
                 URL: https://issues.apache.org/jira/browse/CALCITE-4107
             Project: Calcite
          Issue Type: Bug
          Components: core
    Affects Versions: 1.22.0
            Reporter: JinxinTang


stream sql in batch mode use this will occur `SQL validation failed. From line 
1, column 106 to line 1, column 109: ROW/RANGE not allowed with RANK, 
DENSE_RANK or ROW_NUMBER functions`

 

Reproduce code:

CREATE TABLE src (
 name STRING,
 age BIGINT
) WITH (
 'connector' = 'values'
)

create view src_view as select *, ROW_NUMBER() OVER (PARTITION BY name ORDER BY 
age DESC) as row_num from src

select name, age, row_num from src_view where row_num <= 3

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to