Release events after they have been sent. (#711)

ozontech · Dec 5, 2024 · 49541c3 · 49541c3
1 parent 67a1249
commit 49541c3
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pipeline/batch.go b/pipeline/batch.go
@@ -246,6 +246,7 @@ func (b *Batcher) commitBatch(batch *Batch) BatchStatus {
 
 	for i := range batch.events {
 		b.opts.Controller.Commit(batch.events[i])
+		batch.events[i] = nil
 	}
 
 	status := batch.status