[ 
https://issues.apache.org/jira/browse/FLINK-37384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Junrui Lee closed FLINK-37384.
------------------------------
    Resolution: Fixed

masterĀ 

741ff29b67535427eedb7b8a757b6acbd12c40e5

d45f0da6d02e5260e015f771c36bea4474b0cb0e

release-2.0

f967ff8b9a4e05e0edaf1d7270baa34b418f25d9

37b515cf38e03104c8ec0475e1851f5b6abb0d74

> the execution time of DefaultVertexParallelismAndInputInfosDecider exceeds 
> expectations in specific scenarios
> -------------------------------------------------------------------------------------------------------------
>
>                 Key: FLINK-37384
>                 URL: https://issues.apache.org/jira/browse/FLINK-37384
>             Project: Flink
>          Issue Type: Bug
>          Components: Runtime / Coordination
>            Reporter: Lei Yang
>            Assignee: Lei Yang
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 2.0.0
>
>         Attachments: 
> 27A64A61-E9C3-453C-B7FA-2272D23CA8D2-503-000000D527913C6E.PNG
>
>
> When a Flink job contains a rescale edge converted from hash egde, the 
> execution time of DefaultVertexParallelismAndInputInfosDecider exceeds 
> expectations. This can be reproduced in TPCDS q30 with AQE enabled.  
> !27A64A61-E9C3-453C-B7FA-2272D23CA8D2-503-000000D527913C6E.PNG|width=688,height=183!



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to