chore(blooms): Return decompression reader to pool (#16001)

grafana · Feb 1, 2025 · ac8d79e · ac8d79e
1 parent 319bb0f
commit ac8d79e
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/storage/bloom/v1/index.go b/pkg/storage/bloom/v1/index.go
@@ -102,6 +102,7 @@ func (b *BlockIndex) NewSeriesPageDecoder(r io.ReadSeeker, header SeriesPageHead
 	if err != nil {
 		return nil, errors.Wrap(err, "getting decompressor")
 	}
+	defer b.opts.Schema.DecompressorPool().PutReader(decompressor)
 
 	decompressed := make([]byte, header.DecompressedLen)
 	if _, err = io.ReadFull(decompressor, decompressed); err != nil {