diff --git a/wal.go b/wal.go index 8a2095aed..c1b9f6b06 100644 --- a/wal.go +++ b/wal.go @@ -937,7 +937,7 @@ func (r *walReader) Read( series = v.([]RefSeries) } - err := r.decodeSeries(flag, b, &series) + err = r.decodeSeries(flag, b, &series) if err != nil { err = errors.Wrap(err, "decode series entry") break @@ -958,7 +958,7 @@ func (r *walReader) Read( samples = v.([]RefSample) } - err := r.decodeSamples(flag, b, &samples) + err = r.decodeSamples(flag, b, &samples) if err != nil { err = errors.Wrap(err, "decode samples entry") break @@ -980,7 +980,7 @@ func (r *walReader) Read( deletes = v.([]Stone) } - err := r.decodeDeletes(flag, b, &deletes) + err = r.decodeDeletes(flag, b, &deletes) if err != nil { err = errors.Wrap(err, "decode delete entry") break