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

Martijn Visser updated FLINK-31821:
-----------------------------------
    Component/s: Table SQL / API
                     (was: API / Core)

> FlinkSQL set parallelism for each operator.
> -------------------------------------------
>
>                 Key: FLINK-31821
>                 URL: https://issues.apache.org/jira/browse/FLINK-31821
>             Project: Flink
>          Issue Type: New Feature
>          Components: Table SQL / API
>    Affects Versions: 1.16.1
>            Reporter: hanqing
>            Priority: Critical
>         Attachments: image-2023-04-17-17-31-34-709.png
>
>   Original Estimate: 168h
>  Remaining Estimate: 168h
>
> Currently, FlinkSQL can  set a unified parallelism in the job,it cannot set 
> parallelism for each operator.
> This can cause resource waste  On the occasion of  high parallelism and small 
> data volume.there may also be too many small file  for  writing HDFS Scene.



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

Reply via email to