From 411afdac5f5e0c5e928828b64ff0dad91ea20932 Mon Sep 17 00:00:00 2001 From: hardikl Date: Wed, 13 May 2026 15:15:52 +0530 Subject: [PATCH] fix: handled non-matched ems events --- cmd/collectors/ems/ems.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/cmd/collectors/ems/ems.go b/cmd/collectors/ems/ems.go index 499bd1912..aceaeb950 100644 --- a/cmd/collectors/ems/ems.go +++ b/cmd/collectors/ems/ems.go @@ -548,12 +548,14 @@ func (e *Ems) HandleResults(result []gjson.Result, prop map[string][]*emsProp) ( ) } } else { + existingEms := false if _, ok := m[msgName]; !ok { // create matrix if not exists for the ems event mx = matrix.New(msgName, e.Prop.Object, msgName) mx.SetGlobalLabels(e.Matrix[e.Object].GetGlobalLabels()) m[msgName] = mx } else { + existingEms = true mx = m[msgName] } @@ -671,6 +673,9 @@ func (e *Ems) HandleResults(result []gjson.Result, prop map[string][]*emsProp) ( } if !isMatch { mx.RemoveInstance(instanceKey) + if !existingEms { + delete(m, msgName) + } continue } count += instanceLabelCount