Skip to content

Commit b483fb7

Browse files
authored
Merge pull request #64 from weaveworks/fix-chunk-purging
Fix removal of persisted chunks from memory
2 parents 28b46fa + c763a62 commit b483fb7

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

ingester/ingester.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -474,7 +474,7 @@ func (i *Ingester) flushSeries(ctx context.Context, u *userState, fp model.Finge
474474

475475
// now remove the chunks
476476
u.fpLocker.Lock(fp)
477-
series.chunkDescs = series.chunkDescs[len(chunks)-1:]
477+
series.chunkDescs = series.chunkDescs[len(chunks):]
478478
i.memoryChunks.Sub(float64(len(chunks)))
479479
if len(series.chunkDescs) == 0 {
480480
u.fpToSeries.del(fp)

0 commit comments

Comments
 (0)