修复获取TopN的Broker指标时，会出现部分指标缺失的问题

2025-12-24 20:22:12 +08:00 · 2022-10-11 16:54:39 +08:00
parent 12ebc32cec
commit 50482c40d5
1 changed files with 1 additions and 1 deletions
--- a/km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/BrokerMetricESDAO.java
+++ b/km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/BrokerMetricESDAO.java
@@ -92,7 +92,7 @@ public class BrokerMetricESDAO extends BaseMetricESDAO {
        Table<String, Long, List<MetricPointVO>> table = HashBasedTable.create();

        //2、查询指标
-        for(String metric : metricBrokerIds.keySet()){
+        for(String metric : metrics) {
            table.putAll(
                    this.listBrokerMetricsByBrokerIds(
                            clusterPhyId,