From 9383976918229d6f9efaf6bf103e4e3628d226b9 Mon Sep 17 00:00:00 2001 From: ning1875 <907974064@qq.com> Date: Wed, 4 Aug 2021 12:14:47 +0800 Subject: [PATCH] 1. delete recovery event from cache after event is really mark recovery (#758) --- judge/last_event.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/judge/last_event.go b/judge/last_event.go index 98ba554a..04462450 100644 --- a/judge/last_event.go +++ b/judge/last_event.go @@ -46,7 +46,6 @@ func (s *SafeEventMap) DeleteOrSendRecovery(promql string, toKeepKeys map[string } if ev.ReadableExpression == promql { logger.Debugf("[to_del][ev.IsRecovery:%+v][ev.LastSend:%+v][promql:%v]", ev.IsRecovery, ev.LastSend, promql) - delete(s.M, k) now := time.Now().Unix() // promql 没查询到结果,需要将告警标记为已恢复并发送 // 同时需要满足 已经发送过触发信息,并且时间差满足 大于AlertDuration @@ -55,6 +54,7 @@ func (s *SafeEventMap) DeleteOrSendRecovery(promql string, toKeepKeys map[string logger.Debugf("[prom.alert.MarkRecov][promql:%v][ev.RuleName:%v]", promql, ev.RuleName) ev.MarkRecov() EventQueue.PushFront(ev) + delete(s.M, k) } } }