clarify which segments are deleted when we find a corrupted segment (#522)

Signed-off-by: Callum Styan <callumstyan@gmail.com>
This commit is contained in:
Callum Styan 2019-02-13 19:44:19 -08:00 committed by Krasi Georgiev
parent 74093f0508
commit 89ee5aaed4

View file

@ -296,7 +296,7 @@ func (w *WAL) Repair(origErr error) error {
if err != nil { if err != nil {
return errors.Wrap(err, "list segments") 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 { for _, s := range segs {
if w.segment.i == s.index { if w.segment.i == s.index {