From 588804f62c21e66c8fd26b5d28313ee6171121bd Mon Sep 17 00:00:00 2001
From: wenyh <44251917+wenyh1@users.noreply.github.com>
Date: Thu, 3 Aug 2023 17:35:15 +0800
Subject: [PATCH] [inner-2218] fill AP_NODE_LACK alarm

---
 .../dble/config/helper/TestSchemasTaskForClickHouse.java  | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/actiontech/dble/config/helper/TestSchemasTaskForClickHouse.java b/src/main/java/com/actiontech/dble/config/helper/TestSchemasTaskForClickHouse.java
index 05ef8940b..f8f9cef4d 100644
--- a/src/main/java/com/actiontech/dble/config/helper/TestSchemasTaskForClickHouse.java
+++ b/src/main/java/com/actiontech/dble/config/helper/TestSchemasTaskForClickHouse.java
@@ -6,6 +6,10 @@
 package com.actiontech.dble.config.helper;
 
 import com.actiontech.dble.DbleServer;
+import com.actiontech.dble.alarm.AlarmCode;
+import com.actiontech.dble.alarm.Alert;
+import com.actiontech.dble.alarm.AlertUtil;
+import com.actiontech.dble.alarm.ToResolveContainer;
 import com.actiontech.dble.backend.datasource.ApNode;
 import com.actiontech.dble.backend.datasource.PhysicalDbInstance;
 import com.actiontech.dble.route.parser.util.Pair;
@@ -98,10 +102,10 @@ public class TestSchemasTaskForClickHouse extends Thread {
                 String key = "dbInstance[" + ds.getDbGroupConfig().getName() + "." + ds.getConfig().getInstanceName() + "],ap_node[" + nodeName + "],schema[" + node.getKey() + "]";
                 LOGGER.warn("SelfCheck### test " + key + " database connection fail ");
                 if (needAlert) {
-                   /* Map<String, String> labels = AlertUtil.genSingleLabel("dbInstance", ds.getDbGroupConfig().getName() + "-" + ds.getConfig().getInstanceName());
+                    Map<String, String> labels = AlertUtil.genSingleLabel("dbInstance", ds.getDbGroupConfig().getName() + "-" + ds.getConfig().getInstanceName());
                     labels.put("ap_node", nodeName);
                     AlertUtil.alert(AlarmCode.AP_NODE_LACK, Alert.AlertLevel.WARN, "{" + key + "} is lack", "mysql", ds.getConfig().getId(), labels);
-                    ToResolveContainer.AP_NODE_LACK.add(key);*/
+                    ToResolveContainer.AP_NODE_LACK.add(key);
                 }
             }
         }