gian/cubefs
1
0
Fork 0
mirror of https://github.com/cubefs/cubefs.git synced 2026-08-02 02:00:56 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix(master): Don't show disk decommissionSuccess alerts triggered by node decommission.

Browse Source 
.#1000336575

Signed-off-by: zhumingze <zhumingze@oppo.com>
This commit is contained in:
zhumingze 2025-09-12 15:26:05 +08:00 committed by 常亮
parent 9808c33d84
commit 2f64db405b
1 changed files with 14 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
master/monitor_metrics.go
View File

@ -986,10 +986,20 @@ func (mm *monitorMetrics) setDiskDecommissionedMetric() {
if !ok {
return true
}
disks := dataNode.getDecommissionSuccessDisks()
for _, disk := range disks {
key := fmt.Sprintf("%s_%s", dataNode.Addr, disk)
mm.diskDecommissionSuccess.SetWithLabelValues(1, dataNode.Addr, key)
if dataNode.GetDecommissionStatus() != DecommissionInitial &&
dataNode.GetDecommissionStatus() != DecommissionFail {
return true
}
successDisks := dataNode.getDecommissionSuccessDisks()
successDiskMap := make(map[string]struct{})
for _, disk := range successDisks {
successDiskMap[disk] = struct{}{}
}
for _, badDisk := range dataNode.BadDisks {
if _, exists := successDiskMap[badDisk]; exists {
key := fmt.Sprintf("%s_%s", dataNode.Addr, badDisk)
mm.diskDecommissionSuccess.SetWithLabelValues(1, dataNode.Addr, key)
}
}
return true
})