You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by dm...@apache.org on 2024/01/29 15:18:13 UTC
(flink) 04/07: [hotfix] Speed up AdaptiveSchedulerClusterITCase by setting scalingIntervalMin to 1ms.
This is an automated email from the ASF dual-hosted git repository.
dmvk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 23377711ea4615749adfb9c102e9d38978d6d7b2
Author: David Moravek <dm...@apache.org>
AuthorDate: Mon Nov 6 14:05:30 2023 +0100
[hotfix] Speed up AdaptiveSchedulerClusterITCase by setting scalingIntervalMin to 1ms.
---
.../runtime/scheduler/adaptive/AdaptiveSchedulerClusterITCase.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerClusterITCase.java b/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerClusterITCase.java
index adc8a2ee689..aa9ada19b91 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerClusterITCase.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerClusterITCase.java
@@ -88,8 +88,8 @@ public class AdaptiveSchedulerClusterITCase extends TestLogger {
final Configuration configuration = new Configuration();
configuration.set(JobManagerOptions.SCHEDULER, JobManagerOptions.SchedulerType.Adaptive);
- configuration.set(
- JobManagerOptions.RESOURCE_STABILIZATION_TIMEOUT, Duration.ofMillis(100L));
+ configuration.set(JobManagerOptions.RESOURCE_STABILIZATION_TIMEOUT, Duration.ofMillis(1L));
+ configuration.set(JobManagerOptions.SCHEDULER_SCALING_INTERVAL_MIN, Duration.ofMillis(1L));
// required for #testCheckpointStatsPersistedAcrossRescale
configuration.set(WebOptions.CHECKPOINTS_HISTORY_SIZE, Integer.MAX_VALUE);