Skip to content

Commit 5e078f9

Browse files
authored
Fixed 'wait ring stability' log (#4306)
Signed-off-by: Marco Pracucci <marco@pracucci.com>
1 parent 20f8931 commit 5e078f9

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

pkg/compactor/compactor.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -408,9 +408,9 @@ func (c *Compactor) starting(ctx context.Context) error {
408408

409409
level.Info(c.logger).Log("msg", "waiting until compactor ring topology is stable", "min_waiting", minWaiting.String(), "max_waiting", maxWaiting.String())
410410
if err := ring.WaitRingStability(ctx, c.ring, RingOp, minWaiting, maxWaiting); err != nil {
411-
level.Warn(c.logger).Log("msg", "compactor is ring topology is not stable after the max waiting time, proceeding anyway")
411+
level.Warn(c.logger).Log("msg", "compactor ring topology is not stable after the max waiting time, proceeding anyway")
412412
} else {
413-
level.Info(c.logger).Log("msg", "compactor is ring topology is stable")
413+
level.Info(c.logger).Log("msg", "compactor ring topology is stable")
414414
}
415415
}
416416
}

pkg/storegateway/gateway.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -242,9 +242,9 @@ func (g *StoreGateway) starting(ctx context.Context) (err error) {
242242

243243
level.Info(g.logger).Log("msg", "waiting until store-gateway ring topology is stable", "min_waiting", minWaiting.String(), "max_waiting", maxWaiting.String())
244244
if err := ring.WaitRingStability(ctx, g.ring, BlocksOwnerSync, minWaiting, maxWaiting); err != nil {
245-
level.Warn(g.logger).Log("msg", "store-gateway is ring topology is not stable after the max waiting time, proceeding anyway")
245+
level.Warn(g.logger).Log("msg", "store-gateway ring topology is not stable after the max waiting time, proceeding anyway")
246246
} else {
247-
level.Info(g.logger).Log("msg", "store-gateway is ring topology is stable")
247+
level.Info(g.logger).Log("msg", "store-gateway ring topology is stable")
248248
}
249249
}
250250
}

0 commit comments

Comments
 (0)