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)