From 39cccd568e226ec4c7862ab896fce4fdf88fd841 Mon Sep 17 00:00:00 2001 From: xuguang Date: Thu, 16 Dec 2021 14:17:45 +0800 Subject: [PATCH] =?UTF-8?q?DiDiHealthScoreStrategy=E7=B1=BB=E4=B8=AD?= =?UTF-8?q?=E6=9F=90=E4=BA=9B=E5=8F=98=E9=87=8F=E5=BC=80=E5=A4=B4=E5=AD=97?= =?UTF-8?q?=E6=AF=8D=E6=94=B9=E6=88=90=E5=B0=8F=E5=86=99?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../healthscore/DidiHealthScoreStrategy.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/strategy/healthscore/DidiHealthScoreStrategy.java b/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/strategy/healthscore/DidiHealthScoreStrategy.java index d75dec5a..fed4ccda 100644 --- a/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/strategy/healthscore/DidiHealthScoreStrategy.java +++ b/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/strategy/healthscore/DidiHealthScoreStrategy.java @@ -89,15 +89,15 @@ public class DidiHealthScoreStrategy extends AbstractHealthScoreStrategy { return HEALTH_SCORE_BAD; } - Object RequestHandlerAvgIdlePercentOneMinuteRate = metrics.getMetricsMap().get("RequestHandlerAvgIdlePercentOneMinuteRate"); - Object NetworkProcessorAvgIdlePercentValue = metrics.getMetricsMap().get("NetworkProcessorAvgIdlePercentValue"); - if (ValidateUtils.isNull(RequestHandlerAvgIdlePercentOneMinuteRate) - || ValidateUtils.isNull(NetworkProcessorAvgIdlePercentValue)) { + Object requestHandlerAvgIdlePercentOneMinuteRate = metrics.getMetricsMap().get("RequestHandlerAvgIdlePercentOneMinuteRate"); + Object networkProcessorAvgIdlePercentValue = metrics.getMetricsMap().get("NetworkProcessorAvgIdlePercentValue"); + if (ValidateUtils.isNull(requestHandlerAvgIdlePercentOneMinuteRate) + || ValidateUtils.isNull(networkProcessorAvgIdlePercentValue)) { // 数据获取失败 return Constant.INVALID_CODE; } - if (((Double) RequestHandlerAvgIdlePercentOneMinuteRate) < MIN_IDLE * KAFKA_REQUEST_HANDLER_POOL_SIZE - || ((Double) NetworkProcessorAvgIdlePercentValue) < MIN_IDLE) { + if (((Double) requestHandlerAvgIdlePercentOneMinuteRate) < MIN_IDLE * KAFKA_REQUEST_HANDLER_POOL_SIZE + || ((Double) networkProcessorAvgIdlePercentValue) < MIN_IDLE) { return HEALTH_SCORE_NORMAL; } return HEALTH_SCORE_HEALTHY;