diff --git a/storage/local/crashrecovery.go b/storage/local/crashrecovery.go index 17626c07c..2f695f10b 100644 --- a/storage/local/crashrecovery.go +++ b/storage/local/crashrecovery.go @@ -362,6 +362,10 @@ func (p *persistence) sanitizeSeries( ) numMemChunkDescs.Sub(float64(keepIdx)) atomic.AddInt64(&numMemChunks, int64(-keepIdx)) + if keepIdx == len(s.chunkDescs) { + // No chunks from series file left, head chunk is evicted, so declare it closed. + s.headChunkClosed = true + } s.chunkDescs = append(cds, s.chunkDescs[keepIdx:]...) return fp, true }