[FLINK-32437] Determine and set correct maxParallelism for operator chains

• Type: Bug
• Status: In Progress
• Priority: Major
• Resolution: Unresolved
• Fix Version/s: 2.0.0
• Component/s: API / DataStream
• Labels: pull-request-available stale-assigned
• Assignee: Stefan Richter
• Reporter: Stefan Richter
• Created: 26/Jun/23 08:15
• Updated: 10/Aug/23 22:35

Description

Current code in StreamingJobGraphGenerator does not properly determine and set the correct maxParallelism of operator chains. We should set the maxParallelism of the chain as the minimum of all the maxParallelism values among operators in the chain.

Issue Links

• links to: GitHub Pull Request #22864