Apache Flink 分区算子Rebalance剖析
1.概述1.1定义Rebalance算子是一种平衡分区算子,它将数据均匀分配到所有分区中。Rebalance算子适用于数据倾斜的情况下,可以使所有分区的数据量相近,避免某些分区的数据过多导致性能下降。1.2Rebalance算子的实现流程A
8小时前10
1.概述1.1定义Rebalance算子是一种平衡分区算子,它将数据均匀分配到所有分区中。Rebalance算子适用于数据倾斜的情况下,可以使所有分区的数据量相近,避免某些分区的数据过多导致性能下降。1.2Rebalance算子的实现流程A