[
https://issues.apache.org/jira/browse/FLINK-36149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luolei updated FLINK-36149:
---------------------------
Description:
{code:java}
select *
from
(
SELECT *, ROW_NUMBER() OVER (PARTITION BY song_id, user_id, FLOOR(proc_time
TO day) order by proc_time asc ) as row_num
from tableA
where cmd = 1 and user_id > 0
)
where row_num <=10 {code}
> Support cleaning up expired states to prevent the continuous increase of
> states.
> --------------------------------------------------------------------------------
>
> Key: FLINK-36149
> URL: https://issues.apache.org/jira/browse/FLINK-36149
> Project: Flink
> Issue Type: Improvement
> Reporter: luolei
> Priority: Major
>
> {code:java}
> select *
> from
> (
> SELECT *, ROW_NUMBER() OVER (PARTITION BY song_id, user_id,
> FLOOR(proc_time TO day) order by proc_time asc ) as row_num
> from tableA
> where cmd = 1 and user_id > 0
> )
> where row_num <=10 {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
