[
https://issues.apache.org/jira/browse/CALCITE-4107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JinxinTang updated CALCITE-4107:
--------------------------------
Description:
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
was:
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
> 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
>
> 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
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
