diff --git a/pkg/storage/ingest/reader.go b/pkg/storage/ingest/reader.go
index 78da9b520e1..8288a806ca1 100644
--- a/pkg/storage/ingest/reader.go
+++ b/pkg/storage/ingest/reader.go
@@ -902,7 +902,7 @@ func newConcurrentFetchers(
 		startOffsets:         startOffsetsReader,
 		trackCompressedBytes: trackCompressedBytes,
 		tracer:               recordsTracer(),
-		orderedFetches:       make(chan fetchResult),
+		orderedFetches:       make(chan fetchResult, 1),
 	}
 
 	var err error