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

Posted to issues@flink.apache.org by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/01/15 06:08:00 UTC

[jira] [Updated] (FLINK-27748) AdaptiveScheduler should support operator fixed parallelism

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

ASF GitHub Bot updated FLINK-27748:
-----------------------------------
    Labels: pull-request-available  (was: )

> AdaptiveScheduler should support operator fixed parallelism
> -----------------------------------------------------------
>
>                 Key: FLINK-27748
>                 URL: https://issues.apache.org/jira/browse/FLINK-27748
>             Project: Flink
>          Issue Type: Improvement
>          Components: Runtime / Task
>            Reporter: john
>            Priority: Minor
>              Labels: pull-request-available
>
> In the job topology, if the user specifies the concurrency of the operator, AdaptiveScheduler should support the operator's maximum parallelism equal to the user-specified parallelism during the scheduling process. And the minimum parallelism is equal to the number of slots available to the cluster. 
> This is especially useful in certain scenarios,
> For example, the parallelism of an operator that consumes Kafka is specified to be equal to the number of partitions. Or you want to control the write rate of the operator, etc.



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