From 344cec19fe4974dd69c9646efcb50489ca649883 Mon Sep 17 00:00:00 2001
From: wyb <1164642317@qq.com>
Date: Mon, 19 Dec 2022 16:54:18 +0800
Subject: [PATCH] =?UTF-8?q?[Bugfix]connector=E6=8C=87=E6=A0=87=E9=87=87?=
 =?UTF-8?q?=E9=9B=86=E7=AE=97=E6=9C=80=E5=A4=A7=E5=80=BC=E9=94=99=E8=AF=AF?=
 =?UTF-8?q?(#836)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../connect/connector/impl/ConnectorMetricServiceImpl.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/impl/ConnectorMetricServiceImpl.java b/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/impl/ConnectorMetricServiceImpl.java
index c40d1ee1..a92672c5 100644
--- a/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/impl/ConnectorMetricServiceImpl.java
+++ b/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/impl/ConnectorMetricServiceImpl.java
@@ -312,8 +312,8 @@ public class ConnectorMetricServiceImpl extends BaseConnectorMetricService imple
             return Result.buildFailure(NOT_EXIST);
         }
 
-        Float sum = ret.getData().stream().max((a, b) -> a.getMetric(metric).compareTo(b.getMetric(metric))).get().getMetric(metric);
-        ConnectorMetrics connectorMetrics = ConnectorMetrics.initWithMetric(connectClusterId, connectorName, metric, sum / ret.getData().size());
+        Float max = ret.getData().stream().max((a, b) -> a.getMetric(metric).compareTo(b.getMetric(metric))).get().getMetric(metric);
+        ConnectorMetrics connectorMetrics = ConnectorMetrics.initWithMetric(connectClusterId, connectorName, metric, max);
         return Result.buildSuc(connectorMetrics);
     }