From 0b41fd6e716f3e8b79016f73b6dd77fdf5fcdced Mon Sep 17 00:00:00 2001 From: chavacava Date: Tue, 12 Apr 2022 12:30:20 +0200 Subject: [PATCH] Fix data races in WAL replay (#10571) Signed-off-by: chavacava --- tsdb/agent/db.go | 1 + tsdb/head_wal.go | 1 + 2 files changed, 2 insertions(+) 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) {