Re: 在子查询上使用row_number over返回的rn都是1

Posted by star on Aug 28, 2019; 2:08am
URL: http://apache-flink.370.s1.nabble.com/row-number-over-rn-1-tp501p535.html

谢谢回复，是我sql理解的问题，给您添麻烦了。
另外我还想问一下，这个retractstream后面接了一个process算子来维护top5的list，这个算子是不是还需要自己实现维护state的代码？

> 在 2019年8月28日，09:53，Jark Wu <[hidden email]> 写道：
>
> Hi，
>
> 你使用的是 flink 1.9 blink planner 吧？
>
> 首先你的 topn query 没有问题。结果也没有问题。
> 因为你是根据 province 分组求 top5，也就是每个省份排名前5的 id。但是现在你的数据中，每个省份只有一个 id，所以大家的排名都是1。
> 如果你想求全局前5名的省份，那么row_number 那里不需要定义 partition by province。
>
> Best,
> Jark
>
>
>> 在 2019年8月27日，15:16，ddwcg <[hidden email]> 写道：
>>
>> 6> (true,id001,上海,647.55,1)
>