From 325353b0ebb8b1bdc3be736013bbf4b6868c3952 Mon Sep 17 00:00:00 2001 From: Alex Le Date: Mon, 30 Jun 2025 11:51:55 -0700 Subject: [PATCH] Fixed memory leak in PushStream caused by reusing context Signed-off-by: Alex Le --- pkg/ingester/ingester.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/ingester/ingester.go b/pkg/ingester/ingester.go index 5220308a6a1..c3a151509c4 100644 --- a/pkg/ingester/ingester.go +++ b/pkg/ingester/ingester.go @@ -1576,8 +1576,8 @@ func (i *Ingester) PushStream(srv client.Ingester_PushStreamServer) error { if err != nil { return err } - ctx = user.InjectOrgID(ctx, req.TenantID) - resp, err := i.Push(ctx, req.Request) + pushCtx := user.InjectOrgID(ctx, req.TenantID) + resp, err := i.Push(pushCtx, req.Request) if resp == nil { resp = &cortexpb.WriteResponse{} }