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

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

Done via d9dd5dce00e2389a8ebadf7c15d8f4a0f99f535e

> 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
>              Labels: pull-request-available
>             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