Merge pull request #3170 from tomwilkie/1.7-2969-negative-shards

Prevent number of remote write shards from going negative.
2017-09-14 13:29:34 +02:00 · 2017-09-14 13:29:34 +02:00 · df4bc3e407
parent 4d8e7ca185 4f8efdbd59
commit df4bc3e407
1 changed files with 2 additions and 0 deletions
--- a/storage/remote/queue_manager.go
+++ b/storage/remote/queue_manager.go
@ -339,6 +339,8 @@ func (t *QueueManager) calculateDesiredShards() {
 	numShards := int(math.Ceil(desiredShards))
 	if numShards > t.cfg.MaxShards {
 		numShards = t.cfg.MaxShards
+	} else if numShards < 1 {
+		numShards = 1
 	}
 	if numShards == t.numShards {
 		return