You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Stefan Richter (Jira)" <ji...@apache.org> on 2023/06/26 08:16:00 UTC

[jira] [Created] (FLINK-32437) Determine and set correct maxParallelism for operator chains

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)