你好 
       可以参考一下这个链接的思路 

https://blog.csdn.net/IT_Lee_J_H/article/details/88641894

发自我的iPhone

> 在 2020年4月4日,18:15,chanamper <[email protected]> 写道:
> 
> Dear All,
>    大家好,请教一下。目前针对Java Api的方式,对于Flink keyby情况存在key数据倾斜有啥实现优化思路吗?看官方文档目前在table 
> api和sql层面,有Minibatch Aggregation和Local Global Aggregation方式的实现,针对Java 
> Api的方式有啥办法可以达到local global aggregation的效果吗?
>      多谢!

回复