filter??filter??
-- --
??:
"user-zh"
Hi！
Flink SQL 里已经内置了很多解倾斜的方式，例如 local global 聚合。详见 [1]，如果一定要使用 streaming api
可以参考该思路进行优化。
[1]
https://ci.apache.org/projects/flink/flink-docs-master/zh/docs/dev/table/tuning/#local-global-%e8%81%9a%e5%90%88
xiazhl 于2021年10月26日周二 下午2:31写道：
> hello everyone！
> 向大家求助一个使用keyby
hello everyone??
??keyby??
??flink
streamAPI?? 10
??flinkidkeyby
id
hello everyone??
??keyby??
??flink
streamAPI?? 10
??flinkidkeyby
id???
hi
KeyGroupStreamPartitioner#selectChannel .
Best
JasonLee
??2021??8??30?? 22:34??cs<58683...@qq.com.INVALID> ??
flink??keybykey??tasktask??id
flink??keybykey??tasktask??id
多谢，我试试哈！
| |
陈建平
|
|
邮箱：chanam...@163.com
|
签名由 网易邮箱大师 定制
在2020年04月05日 22:18，戴嘉诚 写道：
你好
可以参考一下这个链接的思路
https://blog.csdn.net/IT_Lee_J_H/article/details/88641894
发自我的iPhone
> 在 2020年4月4日，18:15，chanamper 写道：
>
> Dear All,
>大家好，请教一下。目前针对Java Api的方式，对于Flink keyby情况存在key数
你好
可以参考一下这个链接的思路
https://blog.csdn.net/IT_Lee_J_H/article/details/88641894
发自我的iPhone
> 在 2020年4月4日，18:15，chanamper 写道：
>
> Dear All,
>大家好，请教一下。目前针对Java Api的方式，对于Flink keyby情况存在key数据倾斜有啥实现优化思路吗？看官方文档目前在table
> api和sql层面，有Minibatch Aggregation和Local Global Aggr
：
> Dear All,
> 大家好，请教一下。目前针对Java Api的方式，对于Flink
> keyby情况存在key数据倾斜有啥实现优化思路吗？看官方文档目前在table api和sql层面，有Minibatch
> Aggregation和Local Global Aggregation方式的实现，针对Java Api的方式有啥办法可以达到local global
> aggregation的效果吗？
> 多谢！
Dear All,
大家好，请教一下。目前针对Java Api的方式，对于Flink keyby情况存在key数据倾斜有啥实现优化思路吗？看官方文档目前在table
api和sql层面，有Minibatch Aggregation和Local Global Aggregation方式的实现，针对Java
Api的方式有啥办法可以达到local global aggregation的效果吗？
多谢！
10 matches
Mail list logo
