You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "waywtdcc (Jira)" <ji...@apache.org> on 2022/10/26 05:28:00 UTC

[jira] [Created] (FLINK-29764) Automatic judgment of parallelism of source

waywtdcc created FLINK-29764:
--------------------------------

             Summary: Automatic judgment of parallelism of source
                 Key: FLINK-29764
                 URL: https://issues.apache.org/jira/browse/FLINK-29764
             Project: Flink
          Issue Type: New Feature
          Components: Table SQL / API, Table SQL / Planner
    Affects Versions: 1.15.2, 1.16.0
            Reporter: waywtdcc
             Fix For: 1.17.0


The parallelism of the source is automatically judged. The parallelism of the source should not be determined by jobmanager. adaptive batch scheduler The default source parallelism is judged by the two configurations of jobmanager.adaptive batch-scheduler.min-parallelism and jobmanager.adaptive batch-scheduler.max-parallelism and the number of partitions



--
This message was sent by Atlassian Jira
(v8.20.10#820010)