[hotfix][runtime] Minor clean-up in ThreasholdMeter.

liuzidi · Apr 19, 2021 · 8df651d · 8df651d
1 parent 5fbf0d7
commit 8df651d
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/metrics/ThresholdMeter.java b/flink-runtime/src/main/java/org/apache/flink/runtime/metrics/ThresholdMeter.java
@@ -77,11 +77,12 @@ public long getCount() {
     }
 
     public void checkAgainstThreshold() throws ThresholdExceedException {
-        if (getEventCountsRecentInterval() >= maxEventsPerInterval) {
+        int recentEvents = getEventCountsRecentInterval();
+        if (recentEvents >= maxEventsPerInterval) {
             throw new ThresholdExceedException(
                     String.format(
                             "%d events detected in the recent interval, reaching the threshold %f.",
-                            getEventCountsRecentInterval(), maxEventsPerInterval));
+                            recentEvents, maxEventsPerInterval));
         }
     }