diff --git a/go/mysql/binlog_event_compression.go b/go/mysql/binlog_event_compression.go
index b1fffbc5284..0eb454aa0f9 100644
--- a/go/mysql/binlog_event_compression.go
+++ b/go/mysql/binlog_event_compression.go
@@ -364,7 +364,7 @@ func (dp *decoderPool) Get(reader io.Reader) (*zstd.Decoder, error) {
 	} else {
 		d, err := zstd.NewReader(nil, zstd.WithDecoderMaxMemory(zstdInMemoryDecompressorMaxSize))
 		if err != nil { // Should only happen e.g. due to ENOMEM
-			return nil, vterrors.New(vtrpcpb.Code_INTERNAL, "failed to create stateful stream decoder")
+			return nil, vterrors.Wrap(err, "failed to create stateful stream decoder")
 		}
 		decoder = d
 	}