From 96d55c4471b2a61bd4f173bd52b09a04eb587ee7 Mon Sep 17 00:00:00 2001 From: Edd Robinson Date: Sun, 14 Jan 2018 16:00:10 +0000 Subject: [PATCH] Fix reference bug --- tsdb/index/inmem/meta.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/tsdb/index/inmem/meta.go b/tsdb/index/inmem/meta.go index c027d0e03a..757d28982d 100644 --- a/tsdb/index/inmem/meta.go +++ b/tsdb/index/inmem/meta.go @@ -323,6 +323,8 @@ func (m *measurement) Rebuild() *measurement { for _, id := range m.sortedSeriesIDs { if s := m.seriesByID[id]; s != nil { + // Explicitly set the new measurement on the series. + s.Measurement = nm nm.AddSeries(s) } } @@ -1238,11 +1240,9 @@ func (s *series) AssignShard(shardID uint64, ts int64) { func (s *series) UnassignShard(shardID uint64, ts int64) { s.mu.Lock() - fmt.Println(s.shardIDs) if s.LastModified() < ts { delete(s.shardIDs, shardID) } - fmt.Println(s.shardIDs) s.mu.Unlock() } @@ -1266,7 +1266,6 @@ func (s *series) ShardN() int { // Delete marks this series as deleted. A deleted series should not be returned for queries. func (s *series) Delete(ts int64) { - fmt.Println("Marking series ", s.Key, "as deleted") s.mu.Lock() if s.LastModified() < ts { s.deleted = true