谢谢回复,是我sql理解的问题,给您添麻烦了。 另外我还想问一下,这个retractstream后面接了一个process算子来维护top5的list,这个算子是不是还需要自己实现维护state的代码?
> 在 2019年8月28日,09:53,Jark Wu <imj...@gmail.com> 写道: > > 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 <3149768...@qq.com> 写道: >> >> 6> (true,id001,上海,647.55,1) >