diff --git a/lib/encoding/zstd/stream_pure.go b/lib/encoding/zstd/stream_pure.go index 776de34b65..0a3dae1b44 100644 --- a/lib/encoding/zstd/stream_pure.go +++ b/lib/encoding/zstd/stream_pure.go @@ -18,7 +18,7 @@ type Reader struct { // NewReader returns zstd reader for the given r. func NewReader(r io.Reader) *Reader { - d, err := zstd.NewReader(r) + d, err := zstd.NewReader(r, zstd.WithDecoderConcurrency(1)) if err != nil { logger.Panicf("BUG: unexpected error returned when creating ZSTD reader: %s", err) }