diff --git a/tsdb/agent/db.go b/tsdb/agent/db.go index 7d42d14feb..b0fe1f9627 100644 --- a/tsdb/agent/db.go +++ b/tsdb/agent/db.go @@ -410,6 +410,7 @@ func (db *DB) loadWAL(r *wal.Reader, multiRef map[chunks.HeadSeriesRef]chunks.He go func() { defer close(decoded) + var err error for r.Next() { rec := r.Record() switch dec.Type(rec) { diff --git a/tsdb/head_wal.go b/tsdb/head_wal.go index d0fe685ffb..02f4aeadb0 100644 --- a/tsdb/head_wal.go +++ b/tsdb/head_wal.go @@ -133,6 +133,7 @@ func (h *Head) loadWAL(r *wal.Reader, multiRef map[chunks.HeadSeriesRef]chunks.H go func() { defer close(decoded) + var err error for r.Next() { rec := r.Record() switch dec.Type(rec) {