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)

Reply via email to