在executiongraph中,一个jobvertex有多个executionvertex,当数据从上游流向下游操作符(executionvertex)时,选择哪个executionvertex是非常重要的。Flink给 Shuffle()
, rescale()
, rebalance()
,通过随机循环选择下游顶点。每个操作员可能有不同的计算能力,因此分配相同的任务可能会导致负载不均匀。
flink还有其他方法来实现真正的负载平衡吗
在executiongraph中,一个jobvertex有多个executionvertex,当数据从上游流向下游操作符(executionvertex)时,选择哪个executionvertex是非常重要的。Flink给 Shuffle()
, rescale()
, rebalance()
,通过随机循环选择下游顶点。每个操作员可能有不同的计算能力,因此分配相同的任务可能会导致负载不均匀。
flink还有其他方法来实现真正的负载平衡吗
暂无答案!
目前还没有任何答案,快来回答吧!