Re: flink sql row_number() over () OOM

2019-09-04 Thread liu ze
Thank you for your reply. This is my sql, self-join, calculate the proportion and then get top10 cumstors。 "mytable" has only 60,000 records, after joining, the "records send" is 2,869,940 records, and is still increasing. select * from ( select t1.id, t1.month, t1.customer,

Re: flink sql row_number() over () OOM

2019-09-04 Thread Wesley Peng
Hi on 2019/9/4 19:30, liu ze wrote: I use the row_number() over() function to do topN, the total amount of data is 60,000, and the state is 12G . Finally, oom, is there any way to optimize it? ref:

flink sql row_number() over () OOM

2019-09-04 Thread liu ze
hi, I use the row_number() over() function to do topN, the total amount of data is 60,000, and the state is 12G . Finally, oom, is there any way to optimize it? thanks