[FLINK-38051] Fix flaky test JobAutoScalerImplTest

mateczagany · gyfora · commit 3f4481732621 · 2025-07-09T08:34:48.000+02:00
diff --git a/flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricEvaluator.java b/flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricEvaluator.java
@@ -456,7 +456,10 @@ public static double getRate(
             return Double.NaN;
         }
 
-        return 1000 * (last - first) / Duration.between(firstTs, lastTs).toMillis();
+        long tsDiff = Duration.between(firstTs, lastTs).toMillis();
+        tsDiff = Math.max(tsDiff, 1);
+
+        return 1000 * (last - first) / tsDiff;
     }
 
     public static double getAverage(

Original file line number	Diff line number	Diff line change
`@@ -456,7 +456,10 @@ public static double getRate(`
`456`	`456`	`return Double.NaN;`
`457`	`457`	`}`
`458`	`458`
`459`		`- return 1000 * (last - first) / Duration.between(firstTs, lastTs).toMillis();`
	`459`	`+ long tsDiff = Duration.between(firstTs, lastTs).toMillis();`
	`460`	`+ tsDiff = Math.max(tsDiff, 1);`
	`461`	`+`
	`462`	`+ return 1000 * (last - first) / tsDiff;`
`460`	`463`	`}`
`461`	`464`
`462`	`465`	`public static double getAverage(`