Stefan Richter created FLINK-32437:
--------------------------------------
Summary: Determine and set correct maxParallelism for operator
chains
Key: FLINK-32437
URL: https://issues.apache.org/jira/browse/FLINK-32437
Project: Flink
Issue Type: Bug
Components: API / DataStream
Reporter: Stefan Richter
Assignee: Stefan Richter
Fix For: 1.19.0
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.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
