[FLINK-29693] MiniClusterExtension should respect DEFAULT_PARALLELISM if set

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.17.0, 1.16.1
• Component/s: Tests
• Labels: pull-request-available
• Assignee: Chesnay Schepler
• Reporter: Chesnay Schepler
• Created: 19/Oct/22 14:35
• Updated: 01/Nov/22 09:38
• Resolved: 20/Oct/22 09:54

Description

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.

Issue Links

• is duplicated by: FLINK-29691 Adjust org.apache.flink.test.junit5.MiniClusterExtension#registerEnv to honor DEFAULT_PARALLELISM if set
• links to: GitHub Pull Request #21117