You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "YUJIANBO (Jira)" <ji...@apache.org> on 2021/08/05 09:38:00 UTC
[jira] [Created] (FLINK-23643) I repeated the same problem:
ROW/RANGE not allowed with RANK, DENSE_RANK or ROW_NUMBER functions
YUJIANBO created FLINK-23643:
--------------------------------
Summary: I repeated the same problem: ROW/RANGE not allowed with RANK, DENSE_RANK or ROW_NUMBER functions
Key: FLINK-23643
URL: https://issues.apache.org/jira/browse/FLINK-23643
Project: Flink
Issue Type: Bug
Components: Table SQL / Planner
Affects Versions: 1.12.0
Reporter: YUJIANBO
I found a problem that was fixed in 1.12.0 and FLINK-18440, but I repeated the same problem:
ROW/RANGE not allowed with RANK, DENSE_RANK or ROW_NUMBER functions.
this is my sql:
```
create temporary view tmp as
select
area_zip,
store_id,
product_id,
batch_id,
RANK() over (PARTITION BY area_zip,store_id,product_id ORDER BY ts DESC RANGE BETWEEN INTERVAL '5' MINUTE preceding AND CURRENT ROW) AS num_rank
from pricechangelogs;
insert into print_table
select * from tmp where num_rank = 1;
```
--
This message was sent by Atlassian Jira
(v8.3.4#803005)