diff --git a/wal/wal.go b/wal/wal.go index fd90eb90e..1ab633460 100644 --- a/wal/wal.go +++ b/wal/wal.go @@ -296,7 +296,7 @@ func (w *WAL) Repair(origErr error) error { if err != nil { return errors.Wrap(err, "list segments") } - level.Warn(w.logger).Log("msg", "deleting all segments behind corruption", "segment", cerr.Segment) + level.Warn(w.logger).Log("msg", "deleting all segments newer than corrupted segment", "segment", cerr.Segment) for _, s := range segs { if w.segment.i == s.index {