[FLINK-29500] InitializeOnMaster uses wrong parallelism with AdaptiveScheduler

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.16.0, 1.15.2, 1.14.6
• Fix Version/s: 1.16.0, 1.17.0, 1.15.3
• Component/s: API / Core, Runtime / Coordination
• Labels: pull-request-available
• Assignee: Dawid Wysakowicz
• Reporter: Dawid Wysakowicz
• Created: 04/Oct/22 11:42
• Updated: 20/Oct/22 02:32
• Resolved: 06/Oct/22 15:10

Description

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.

Issue Links

• links to: GitHub Pull Request #20950