Always free buffers

Signed-off-by: Arve Knudsen <[email protected]>
grafana · Dec 13, 2024 · 645003d · 645003d
1 parent 80ab1c7
commit 645003d
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/pkg/distributor/query.go b/pkg/distributor/query.go
@@ -266,9 +266,7 @@ func (d *Distributor) queryIngesterStream(ctx context.Context, replicationSets [
 				cleanup()
 			}
 
-			if err != nil {
-				result.freeBuffers()
-			}
+			result.freeBuffers()
 		}()
 
 		log.Span.SetTag("ingester_address", ing.Addr)
@@ -458,7 +456,7 @@ func (d *Distributor) queryIngesterStream(ctx context.Context, replicationSets [
 			res.streamingSeries.StreamReader.StartBuffering()
 		}
 
-		res.freeBuffers()
+		// res.freeBuffers()
 	}
 
 	// Now turn the accumulated maps into slices.