From cd81d8a5d4d768498a1654665e3bc0129cdeb9ac Mon Sep 17 00:00:00 2001
From: kruskal <99559985+kruskall@users.noreply.github.com>
Date: Sun, 9 Jun 2024 15:11:07 +0200
Subject: [PATCH] fix: remove event.received from aggregated events

---
 x-pack/apm-server/aggregation/lsm.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/x-pack/apm-server/aggregation/lsm.go b/x-pack/apm-server/aggregation/lsm.go
index f680264993..6e4d5c8cb6 100644
--- a/x-pack/apm-server/aggregation/lsm.go
+++ b/x-pack/apm-server/aggregation/lsm.go
@@ -15,6 +15,7 @@ import (
 	"github.com/elastic/apm-aggregation/aggregationpb"
 	"github.com/elastic/apm-aggregation/aggregators"
 	"github.com/elastic/apm-data/model/modelpb"
+	"github.com/elastic/apm-data/model/modelprocessor"
 	"github.com/elastic/elastic-agent-libs/logp"
 )
 
@@ -96,6 +97,7 @@ func wrapNextProcessor(processor modelpb.BatchProcessor) aggregators.Processor {
 		if err != nil {
 			return fmt.Errorf("failed to convert combined metrics to batch: %w", err)
 		}
+		modelprocessor.RemoveEventReceived{}.ProcessBatch(ctx, batch)
 		if err := processor.ProcessBatch(
 			ctx,
 			batch,