You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fa...@apache.org on 2024/02/20 14:21:35 UTC

(flink) 01/02: [hotfix][tests] Disables cool down phase for faster test execution

This is an automated email from the ASF dual-hosted git repository.

fanrui pushed a commit to branch release-1.19
in repository https://gitbox.apache.org/repos/asf/flink.git

commit b7ea090082d374e4788192dc75eabfa0bbca2777
Author: Rui Fan <19...@gmail.com>
AuthorDate: Thu Feb 1 21:09:34 2024 +0800

    [hotfix][tests] Disables cool down phase for faster test execution
---
 .../java/org/apache/flink/test/checkpointing/AutoRescalingITCase.java   | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/AutoRescalingITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/AutoRescalingITCase.java
index eab82b1c727..9b95c8aa41c 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/AutoRescalingITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/AutoRescalingITCase.java
@@ -163,6 +163,8 @@ public class AutoRescalingITCase extends TestLogger {
                     NettyShuffleEnvironmentOptions.NETWORK_BUFFERS_PER_CHANNEL, buffersPerChannel);
 
             config.set(JobManagerOptions.SCHEDULER, JobManagerOptions.SchedulerType.Adaptive);
+            // Disable the scaling cooldown to speed up the test
+            config.set(JobManagerOptions.SCHEDULER_SCALING_INTERVAL_MIN, Duration.ofMillis(0));
 
             // speed the test suite up
             // - lower refresh interval -> controls how fast we invalidate ExecutionGraphCache