Only take recent producer metrics (opensource4you#528)

garyparrot · Jul 29, 2022 · be13aab · be13aab
1 parent a45388a
commit be13aab
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 0 deletions.
diff --git a/app/src/main/java/org/astraea/app/cost/NodeLatencyCost.java b/app/src/main/java/org/astraea/app/cost/NodeLatencyCost.java
@@ -17,6 +17,7 @@
 package org.astraea.app.cost;
 
 import java.util.Collection;
+import java.util.Comparator;
 import java.util.Map;
 import java.util.Optional;
 import java.util.stream.Collectors;
@@ -44,6 +45,10 @@ public BrokerCost brokerCost(ClusterInfo clusterInfo, ClusterBean clusterBean) {
                     Map.Entry::getKey,
                     e ->
                         e.getValue().stream()
+                            .sorted(
+                                Comparator.comparing(HasProducerNodeMetrics::createdTimestamp)
+                                    .reversed())
+                            .limit(1)
                             .mapToDouble(HasProducerNodeMetrics::requestLatencyAvg)
                             .sum()));
     return () -> result;

diff --git a/app/src/main/java/org/astraea/app/cost/NodeThroughputCost.java b/app/src/main/java/org/astraea/app/cost/NodeThroughputCost.java
@@ -17,6 +17,7 @@
 package org.astraea.app.cost;
 
 import java.util.Collection;
+import java.util.Comparator;
 import java.util.Map;
 import java.util.Optional;
 import java.util.stream.Collectors;
@@ -44,6 +45,10 @@ public BrokerCost brokerCost(ClusterInfo clusterInfo, ClusterBean clusterBean) {
                     Map.Entry::getKey,
                     e ->
                         e.getValue().stream()
+                            .sorted(
+                                Comparator.comparing(HasProducerNodeMetrics::createdTimestamp)
+                                    .reversed())
+                            .limit(1)
                             .mapToDouble(m -> m.incomingByteRate() + m.outgoingByteRate())
                             .sum()));
     return () -> result;