From 780fdea2cc1bb6863265ad1078ef7c5224ead4f6 Mon Sep 17 00:00:00 2001 From: zengqiao Date: Tue, 11 Oct 2022 16:54:39 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E8=8E=B7=E5=8F=96TopN?= =?UTF-8?q?=E7=9A=84Broker=E6=8C=87=E6=A0=87=E6=97=B6=EF=BC=8C=E4=BC=9A?= =?UTF-8?q?=E5=87=BA=E7=8E=B0=E9=83=A8=E5=88=86=E6=8C=87=E6=A0=87=E7=BC=BA?= =?UTF-8?q?=E5=A4=B1=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../know/streaming/km/persistence/es/dao/BrokerMetricESDAO.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git 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 index edc186f4..83145381 100644 --- 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> table = HashBasedTable.create(); //2、查询指标 - for(String metric : metricBrokerIds.keySet()){ + for(String metric : metrics) { table.putAll( this.listBrokerMetricsByBrokerIds( clusterPhyId,