This is an automated email from the ASF dual-hosted git repository. wanglijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 2fc90245f570931f75924f4704f5d681ac88ffe4 Author: Lijie Wang <[email protected]> AuthorDate: Fri Feb 10 21:42:38 2023 +0800 [hotfix] Adjust the parameters of AdaptiveBatchSchedulerITCase to make tests more reasonable --- .../apache/flink/test/scheduling/AdaptiveBatchSchedulerITCase.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/flink-tests/src/test/java/org/apache/flink/test/scheduling/AdaptiveBatchSchedulerITCase.java b/flink-tests/src/test/java/org/apache/flink/test/scheduling/AdaptiveBatchSchedulerITCase.java index 2dcc33585cd..cab7aa9ba74 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/scheduling/AdaptiveBatchSchedulerITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/scheduling/AdaptiveBatchSchedulerITCase.java @@ -84,11 +84,11 @@ class AdaptiveBatchSchedulerITCase { final StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironment(configuration); env.setRuntimeMode(RuntimeExecutionMode.BATCH); - env.setParallelism(4); + env.setParallelism(8); final DataStream<Long> source = env.fromSequence(0, NUMBERS_TO_PRODUCE - 1) - .setParallelism(4) + .setParallelism(8) .name("source") .slotSharingGroup("group1"); @@ -169,7 +169,8 @@ class AdaptiveBatchSchedulerITCase { configuration.setString(RestOptions.BIND_PORT, "0"); configuration.setLong(JobManagerOptions.SLOT_REQUEST_TIMEOUT, 5000L); configuration.setInteger( - BatchExecutionOptions.ADAPTIVE_AUTO_PARALLELISM_MAX_PARALLELISM, 2); + BatchExecutionOptions.ADAPTIVE_AUTO_PARALLELISM_MAX_PARALLELISM, + DEFAULT_MAX_PARALLELISM); configuration.set( BatchExecutionOptions.ADAPTIVE_AUTO_PARALLELISM_AVG_DATA_VOLUME_PER_TASK, MemorySize.parse("150kb"));
