[
https://issues.apache.org/jira/browse/CALCITE-4107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stamatis Zampetakis updated CALCITE-4107:
-----------------------------------------
Fix Version/s: 1.27.0
> 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
> Priority: Major
> Fix For: 1.27.0
>
>
> stream sql 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
>
> Related Flink PR is:
> [https://github.com/apache/flink/pull/12819|https://github.com/apache/flink/pull/12819]
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
