diff --git a/pkg/querier-rf1/wal/chunks.go b/pkg/querier-rf1/wal/chunks.go index 15f49836b5b2a..bfe565ff6134b 100644 --- a/pkg/querier-rf1/wal/chunks.go +++ b/pkg/querier-rf1/wal/chunks.go @@ -2,7 +2,6 @@ package wal import ( "context" - "errors" "fmt" "io" "sort" @@ -316,8 +315,8 @@ func readChunkData(ctx context.Context, storage BlockStorage, chunk ChunkData) ( defer reader.Close() data := make([]byte, size) - _, err = reader.Read(data) - if err != nil && !errors.Is(err, io.EOF) { + _, err = io.ReadFull(reader, data) + if err != nil { return nil, fmt.Errorf("could not read socket for %s: %w", chunk.id, err) }