【Flink】随机前缀解决数据倾斜_flink key用随机数-CSDN博客

网友收藏2024-01-23 08:41

链接地址：https://blog.csdn.net/weixin_43589563/article/details/123452258
链接标题：【Flink】随机前缀解决数据倾斜_flink key用随机数-CSDN博客
所属网站：blog.csdn.net
被收藏次数：4620

文章浏览阅读353次。Source如果是多并行度，其采用的是轮询；KeyBy数据倾斜：BroadCast或者Custom广播适合join场景自定义适合groupby场景rebalancerebalance 将数据发往下游所有并行度rescale自定义分区器 //自定义分区器泛型是key 返回值是分区号 source.partitionCustom(new Partitioner<String>() { @Override ._flink key用随机数

本文地址：https://tebull.com/detail/506314.html

标签：flink key用随机数