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

Posted to issues@flink.apache.org by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/11/10 02:14:01 UTC

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

     [ https://issues.apache.org/jira/browse/FLINK-32437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Ruan Hang updated FLINK-32437:
------------------------------
    Fix Version/s: 2.3.0
                       (was: 2.2.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, stale-assigned
>             Fix For: 2.3.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)