From 062e637a6c274f46018468118c53596b5342efab Mon Sep 17 00:00:00 2001 From: mateczagany Date: Sun, 6 Jul 2025 06:23:43 +0200 Subject: [PATCH] [FLINK-38051] Fix flaky test JobAutoScalerImplTest --- .../org/apache/flink/autoscaler/ScalingMetricEvaluator.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) 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 index 58c5dbe4a4..b2a4a277e7 100644 --- 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(