Prevent number of remote write shards from going negative.

This can happen in the situation where the system scales up the number of shards massively (to deal with some backlog), then scales it down again as the number of samples sent during the time period is less than the number received.
pull/2973/head
Tom Wilkie 7 years ago
parent 76c9a0d931
commit 1d94eb8d95

@ -339,6 +339,8 @@ func (t *QueueManager) calculateDesiredShards() {
numShards := int(math.Ceil(desiredShards)) numShards := int(math.Ceil(desiredShards))
if numShards > t.cfg.MaxShards { if numShards > t.cfg.MaxShards {
numShards = t.cfg.MaxShards numShards = t.cfg.MaxShards
} else if numShards < 1 {
numShards = 1
} }
if numShards == t.numShards { if numShards == t.numShards {
return return

Loading…
Cancel
Save