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

Posted to issues@flink.apache.org by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2022/10/04 11:43:00 UTC

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

Dawid Wysakowicz created FLINK-29500:
----------------------------------------

             Summary: 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.14.6, 1.15.2, 1.16.0
            Reporter: Dawid Wysakowicz


{{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)