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)