bug fix

Author: bjrara

plugins/processors/awsapplicationsignals/internal/cardinalitycontrol/metrics_limiter.go

@@ -96,8 +96,16 @@ func (m *MetricsLimiter) Admit(metricName string, attributes, resourceAttributes
 	}
 	admitted := true
 
-	loaded, _ := m.services.LoadOrStore(serviceName, newService(serviceName, m.DropThreshold, m.RotationInterval, m.ctx, m.logger))
-	svc := loaded.(*service)
+	val, loaded := m.services.Load(serviceName)
+	if !loaded {
+		valToStore := newService(serviceName, m.DropThreshold, m.RotationInterval, m.ctx, m.logger)
+		val, loaded = m.services.LoadOrStore(serviceName, valToStore)
+		if loaded {
+			valToStore.cancelFunc()
+			m.logger.Info(fmt.Sprintf("[%s] cancel newly created service entry as an existing one is found", serviceName))
+		}
+	}
+	svc := val.(*service)
 
 	metricData := newMetricData(serviceName, metricName, labels)