You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2022/10/06 15:07:00 UTC

[jira] [Updated] (FLINK-29500) InitializeOnMaster uses wrong parallelism with AdaptiveScheduler

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

ASF GitHub Bot updated FLINK-29500:
-----------------------------------
    Labels: pull-request-available  (was: )

> InitializeOnMaster uses wrong parallelism with AdaptiveScheduler
> ----------------------------------------------------------------
>
>                 Key: FLINK-29500
>                 URL: https://issues.apache.org/jira/browse/FLINK-29500
>             Project: Flink
>          Issue Type: Bug
>          Components: API / Core, Runtime / Coordination
>    Affects Versions: 1.16.0, 1.15.2, 1.14.6
>            Reporter: Dawid Wysakowicz
>            Priority: Major
>              Labels: pull-request-available
>
> {{InputOutputFormatVertex}} uses {{JobVertex#getParallelism}} to invoke {{InitializeOnMaster#initializeGlobal}}. However, this parallelism might not be the actual one which will be used to execute the node in combination with Adaptive Scheduler. In case of Adaptive Scheduler the execution parallelism is provided via {{VertexParallelismStore}}.



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