From 98a5c7b776f9dc5da3b0d25193e7690738418a2d Mon Sep 17 00:00:00 2001 From: fengqiongfeng Date: Thu, 9 Feb 2023 19:09:39 +0800 Subject: [PATCH] =?UTF-8?q?[Optimize]=E5=81=A5=E5=BA=B7=E6=A3=80=E6=9F=A5?= =?UTF-8?q?=E6=97=A5=E5=BF=97=E4=BC=98=E5=8C=96(#869)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../health/checker/cluster/HealthCheckClusterService.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/cluster/HealthCheckClusterService.java b/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/cluster/HealthCheckClusterService.java index 39ee6779..9d31af2d 100644 --- a/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/cluster/HealthCheckClusterService.java +++ b/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/cluster/HealthCheckClusterService.java @@ -58,7 +58,7 @@ public class HealthCheckClusterService extends AbstractHealthCheckService { Result clusterMetricsResult = clusterMetricService.getLatestMetricsFromES(param.getClusterPhyId(), Arrays.asList(ClusterMetricVersionItems.CLUSTER_METRIC_ACTIVE_CONTROLLER_COUNT)); if (clusterMetricsResult.failed() || !clusterMetricsResult.hasData()) { - log.error("method=checkClusterNoController||param={}||config={}||result={}||errMsg=get metrics failed", + log.error("method=checkClusterNoController||param={}||config={}||result={}||errMsg=get metrics from es failed", param, valueConfig, clusterMetricsResult); return null; } @@ -71,7 +71,11 @@ public class HealthCheckClusterService extends AbstractHealthCheckService { ); Float activeController = clusterMetricsResult.getData().getMetric(ClusterMetricVersionItems.CLUSTER_METRIC_ACTIVE_CONTROLLER_COUNT); - + if (activeController == null) { + log.error("method=checkClusterNoController||param={}||config={}||errMsg=get metrics from es failed, activeControllerCount is null", + param, valueConfig); + return null; + } checkResult.setPassed(activeController.intValue() != valueConfig.getValue().intValue() ? 0: 1);