Weijie Guo created FLINK-29101: ---------------------------------- Summary: PipelinedRegionSchedulingStrategy benchmark shows performance degradation Key: FLINK-29101 URL: https://issues.apache.org/jira/browse/FLINK-29101 Project: Flink Issue Type: Bug Components: Runtime / Coordination Affects Versions: 1.16.0 Reporter: Weijie Guo Fix For: 1.16.0
Throw TPC-DS and flink-benchmark testing, we found that PipelinedRegionSchedulingStrategy has performance degradation. By investigation, I can confirm that this was introduced by FLINK-28799 which introduce HYBRID type edge support for scheduling strategy. The key to the problem is for blocking ALL_TO_ALL type edges should only enter the scheduling method when the last execution becomes finished, but the current implementation ignores this fact, resulting in the complexity of O(n ^ 2) in this case. -- This message was sent by Atlassian Jira (v8.20.10#820010)