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

Posted to issues@flink.apache.org by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/10/19 14:36:00 UTC

[jira] [Created] (FLINK-29693) MiniClusterExtension should respect DEFAULT_PARALLELISM if set

Chesnay Schepler created FLINK-29693:
----------------------------------------

             Summary: MiniClusterExtension should respect DEFAULT_PARALLELISM if set
                 Key: FLINK-29693
                 URL: https://issues.apache.org/jira/browse/FLINK-29693
             Project: Flink
          Issue Type: Improvement
          Components: Tests
            Reporter: Chesnay Schepler
            Assignee: Chesnay Schepler
             Fix For: 1.16.0


MiniClusterExtension#registerEnv sets the default parallelism of the environment to the number of the slots the cluster has.

This effectively prevents multiple jobs from running on the same MiniCluster unless they specify a parallelism via the API.
This isn't ideal since it means you can't easily mix workloads during testing.

It would be better if the cluster would check the config for whether {{DEFAULT_PARALLELISM}} was set.



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