From ca0abf26c526377e06a0024c0a1f410b601e6b0f Mon Sep 17 00:00:00 2001 From: Vernon Miller <96601789+aldernero@users.noreply.github.com> Date: Tue, 21 Mar 2023 08:03:43 -0600 Subject: [PATCH] Adds an affirmative log message for successful WAL repair (#12135) * Adds an affirmative log message for successful WAL repair Signed-off-by: Vernon Miller Signed-off-by: Vernon Miller <96601789+aldernero@users.noreply.github.com> Co-authored-by: Ganesh Vernekar --- tsdb/agent/db.go | 1 + tsdb/db.go | 2 ++ 2 files changed, 3 insertions(+) diff --git a/tsdb/agent/db.go b/tsdb/agent/db.go index da74fe4c9d..a17e0d1b98 100644 --- a/tsdb/agent/db.go +++ b/tsdb/agent/db.go @@ -303,6 +303,7 @@ func Open(l log.Logger, reg prometheus.Registerer, rs *remote.Storage, dir strin if err := w.Repair(err); err != nil { return nil, errors.Wrap(err, "repair corrupted WAL") } + level.Info(db.logger).Log("msg", "successfully repaired WAL") } go db.run() diff --git a/tsdb/db.go b/tsdb/db.go index 561867025b..659251c3ca 100644 --- a/tsdb/db.go +++ b/tsdb/db.go @@ -828,11 +828,13 @@ func open(dir string, l log.Logger, r prometheus.Registerer, opts *Options, rngs if err := wbl.Repair(initErr); err != nil { return nil, errors.Wrap(err, "repair corrupted OOO WAL") } + level.Info(db.logger).Log("msg", "Successfully repaired OOO WAL") } else { level.Warn(db.logger).Log("msg", "Encountered WAL read error, attempting repair", "err", initErr) if err := wal.Repair(initErr); err != nil { return nil, errors.Wrap(err, "repair corrupted WAL") } + level.Info(db.logger).Log("msg", "Successfully repaired WAL") } }