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

Posted to issues@flink.apache.org by "Zhu Zhu (Jira)" <ji...@apache.org> on 2023/01/31 15:32:00 UTC

[jira] [Closed] (FLINK-30685) Support mark the transformations whose parallelism is infected by the input transformation

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

Zhu Zhu closed FLINK-30685.
---------------------------
    Resolution: Done

Done via fea9ffedecf81a97de5c31519ade3bab8228e743

> Support mark the transformations whose parallelism is infected by the input transformation
> ------------------------------------------------------------------------------------------
>
>                 Key: FLINK-30685
>                 URL: https://issues.apache.org/jira/browse/FLINK-30685
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Runtime / Coordination
>            Reporter: Junrui Li
>            Assignee: Junrui Li
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 1.17.0
>
>
> In order to chain operators together as much as possible, many downstream operators will use the parallelism of upstream input operators in the table planner.
> If some operators need to have their own defined parallelism, the parallelism will be explicitly set. Therefore, the operator that takes the parallelism of the upstream operator as its own parallelism should be automatically derived by the AdaptiveBatchScheduler.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)