From 10d49e798b7133b8f438a327a5c712e051bc4386 Mon Sep 17 00:00:00 2001
From: Tom Wilkie <tom.wilkie@gmail.com>
Date: Tue, 5 Feb 2019 18:09:37 +0000
Subject: [PATCH] Remove stream from index when its remove from memory.
Signed-off-by: Tom Wilkie <tom.wilkie@gmail.com>
---
pkg/ingester/flush.go | 1 +
1 file changed, 1 insertion(+)
diff --git a/pkg/ingester/flush.go b/pkg/ingester/flush.go
index 9e6bb9bd..23a7d27a 100644
--- a/pkg/ingester/flush.go
+++ b/pkg/ingester/flush.go
@@ -204,6 +204,7 @@ func (i *Ingester) removeFlushedChunks(instance *instance, stream *stream) {
if len(stream.chunks) == 0 {
delete(instance.streams, stream.fp)
+ instance.index.Delete(stream.labels, stream.fp)
instance.streamsRemovedTotal.Inc()
}
}
--
GitLab