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)