delete pendings when recoverRule

f3924dab · UlricQin · ac6f49e6 · f3924dab
隐藏空白更改
内联并排

Showing with 8 addition and 0 deletion

src/server/engine/worker.go src/server/engine/worker.go +8 -0

未找到文件。
--- a/src/server/engine/worker.go
+++ b/src/server/engine/worker.go
@@ -330,6 +330,14 @@ func (r RuleEval) fireEvent(event *models.AlertCurEvent) {
 }

 func (r RuleEval) recoverRule(alertingKeys map[string]struct{}, now int64) {
+	for hash := range r.pendings {
+		if _, has := alertingKeys[hash]; has {
+			continue
+		}
+
+		delete(r.pendings, hash)
+	}
+
 	for hash, event := range r.fires {
 		if _, has := alertingKeys[hash]; has {
 			continue