[ https://issues.apache.org/jira/browse/FLINK-32437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Stefan Richter updated FLINK-32437: ----------------------------------- Fix Version/s: 2.0.0 (was: 1.19.0) > 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 > Priority: Major > Labels: pull-request-available > Fix For: 2.0.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)