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)
