Yun Tang created FLINK-31706:
--------------------------------
Summary: The default source parallelism should be the same as
execution's default parallelism under adaptive batch scheduler
Key: FLINK-31706
URL: https://issues.apache.org/jira/browse/FLINK-31706
Project: Flink
Issue Type: Improvement
Components: Runtime / Coordination
Reporter: Yun Tang
Fix For: 1.18.0
Currently, the sources need to set
{{execution.batch.adaptive.auto-parallelism.default-source-parallelism }} in
the adaptive batch scheduler mode, otherwise, the source parallelism is only 1
by default. A better solution might be set as the default execution parallelism
if no user configured.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)