Update aggregators/aggregator.go

Co-authored-by: Vishal Raj <vishal.raj@elastic.co>
carsonip · Sep 20, 2023 · 92d111e · 92d111e
1 parent dc7e257
commit 92d111e
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/aggregators/aggregator.go b/aggregators/aggregator.go
@@ -599,10 +599,10 @@ func (a *Aggregator) processHarvest(
 	}
 	overflowLogger := nopLogger
 	if a.cfg.OverflowLogging {
-		overflowLogger = a.cfg.Logger.With(zap.Duration("aggregation_interval_ns", aggIvl))
-		if kvs := a.cfg.CombinedMetricsIDToKVs(cmk.ID); len(kvs) > 0 {
-			overflowLogger = overflowLogger.With(otelKVsToZapFields(kvs)...)
-		}
+		fields := append([]zap.Field{
+			zap.Duration("aggregation_interval_ns", aggIvl),
+		}, otelKVsToZapFields(kvs)...)
+		overflowLogger = a.cfg.Logger.WithLazy(fields...)
 	}
 	hs.addOverflows(cm, a.cfg.Limits, overflowLogger)