diff --git a/ingester/ingester.go b/ingester/ingester.go index df1f895aa9d..8e09dca66f7 100644 --- a/ingester/ingester.go +++ b/ingester/ingester.go @@ -474,7 +474,7 @@ func (i *Ingester) flushSeries(ctx context.Context, u *userState, fp model.Finge // now remove the chunks u.fpLocker.Lock(fp) - series.chunkDescs = series.chunkDescs[len(chunks)-1:] + series.chunkDescs = series.chunkDescs[len(chunks):] i.memoryChunks.Sub(float64(len(chunks))) if len(series.chunkDescs) == 0 { u.fpToSeries.del(fp)