remove shards from server memory

influxdata · Apr 23, 2015 · 022cb62 · 022cb62
1 parent c27953a
commit 022cb62
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/server.go b/server.go
@@ -1243,6 +1243,12 @@ func (s *Server) applyDeleteShardGroup(m *messaging.Message) (err error) {
 		s.stats.Add("shardsDeleted", int64(len(g.Shards)))
 		return tx.saveDatabase(db)
 	})
+
+	// remove from lookups.
+	for _, sh := range g.Shards {
+		delete(s.shards, sh.ID)
+	}
+
 	return
 }