mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-01-05 20:30:40 -06:00
Code Issues Packages Projects Releases Wiki Activity

[inner-2218] fill AP_NODE_LACK alarm

Browse Source
This commit is contained in:
wenyh
2023-08-03 17:35:15 +08:00
committed by wenyh1
parent bb99c4d6ae
commit 588804f62c
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/com/actiontech/dble/config/helper/TestSchemasTaskForClickHouse.java
View File

@@ -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);
}
}
}