[
https://issues.apache.org/jira/browse/FLINK-36149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luolei updated FLINK-36149:
---------------------------
Attachment: image-2024-08-24-23-10-29-444.png
> 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
> Attachments: image-2024-08-24-23-09-53-925.png,
> image-2024-08-24-23-10-29-444.png
>
>
> {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)
