Junrui Li created FLINK-30684:
---------------------------------

             Summary: 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
             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