Flink大数据实时计算系列-Flink解决数据倾斜
目录
Flink 算子间数据传递
- Flink 算子间数据传递
- Flink 解决one-to-one数据倾斜
-
- rebalance
- rescale
- Flink 解决Redistributing streams (keyby)数据倾斜
-
- DataStream的partitionCustom方法
- 自定义分区器
- CountryCodeConnectCustomPartitioner
- 测试运行
- key加随机前缀
-
- 自定义分区
- 小表扩容
- Flink系列博客
