address review comments

Author: jonastheis

encoding/codecv7_test.go

@@ -9,7 +9,6 @@ import (
 	"math/big"
 	"math/rand"
 	"net/http"
-	_ "net/http"
 	_ "net/http/pprof"
 	"strings"
 	"testing"
@@ -22,8 +21,8 @@ import (
 	"github.com/stretchr/testify/require"
 )
 
-// TestDecodeAllDeadlock tests the decompression of random bytes to trigger deadlock in zstd library.
-
+// TestDecodeAllDeadlock tests the decompression of random bytes to trigger deadlock in zstd library
+// with setting of zstd.WithDecoderConcurrency(2).
 func TestDecodeAllDeadlock(t *testing.T) {
 	t.Skip("Skip test that triggers deadlock in zstd library")
 

encoding/da.go

@@ -552,7 +552,7 @@ func decompressScrollBlobToBatch(compressedBytes []byte) ([]byte, error) {
 	batchOfBytes := make([]byte, readBatchSize)
 
 	r := bytes.NewReader(compressedBytes)
-	zr, err := zstd.NewReader(r)
+	zr, err := zstd.NewReader(r, zstd.WithDecoderConcurrency(1))
 	if err != nil {
 		return nil, err
 	}