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 <[email protected]> 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);
