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

Zhu Zhu reassigned FLINK-30684:
-------------------------------

    Assignee: Junrui Li

> Use the default parallelism as a flag for vertices that can automatically 
> derive parallelism.
> ---------------------------------------------------------------------------------------------
>
>                 Key: FLINK-30684
>                 URL: https://issues.apache.org/jira/browse/FLINK-30684
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Runtime / Coordination
>            Reporter: Junrui Li
>            Assignee: Junrui Li
>            Priority: Major
>             Fix For: 1.17.0
>
>
> This change proposes to add a *parallelismConfigured* property as a flag to 
> identify whether the parallelism of node is used "parallelism.default" or 
> not. If the vertex's *parallelismConfigured* is true, the 
> AdaptiveBatchScheduler will not automatically deciding parallelisms for it. 
> Otherwise, AdaptiveBatchScheduler will automatically deciding parallelisms 
> and use the "parallelism.default" as an alternative value for the 
> "jobmanager.adaptive-batch-scheduler.max-parallelism".
> This change will make user do not need to configure "parallelism.default" as 
> "-1" to automatically deciding parallelisms for vertices.



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

Reply via email to