diff --git a/storage/remote/queue_manager.go b/storage/remote/queue_manager.go index c47039b4b..6b50b76d1 100644 --- a/storage/remote/queue_manager.go +++ b/storage/remote/queue_manager.go @@ -500,7 +500,7 @@ func (t *QueueManager) updateShardsLoop() { // to stay close to shardUpdateDuration. select { case t.reshardChan <- desiredShards: - level.Info(t.logger).Log("msg", "Remote storage resharding", "from", t.numShards, "to", numShards) + level.Info(t.logger).Log("msg", "Remote storage resharding", "from", t.numShards, "to", desiredShards) t.numShards = desiredShards default: level.Info(t.logger).Log("msg", "Currently resharding, skipping.")