From 68f6226bea3b07be15b0a154b9869b2aae1e7234 Mon Sep 17 00:00:00 2001 From: Anton Kaliaev Date: Tue, 22 May 2018 15:50:23 +0400 Subject: [PATCH] data is corrupted, but this requires manual intervention i.e., can't be skipped and we should only return DataCorruptionError if we can skip a msg safely --- consensus/wal.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/consensus/wal.go b/consensus/wal.go index 7ae36eae5..1abf97293 100644 --- a/consensus/wal.go +++ b/consensus/wal.go @@ -282,7 +282,7 @@ func (dec *WALDecoder) Decode() (*TimedWALMessage, error) { length := binary.BigEndian.Uint32(b) if length > maxMsgSizeBytes { - return nil, DataCorruptionError{fmt.Errorf("length %d exceeded maximum possible value of %d bytes", length, maxMsgSizeBytes)} + return nil, fmt.Errorf("length %d exceeded maximum possible value of %d bytes", length, maxMsgSizeBytes) } data := make([]byte, length)