fix race condition in lz4_raw compression

xitongsys · Aug 17, 2024 · f9fb536 · f9fb536
1 parent 9ddb178
commit f9fb536
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/compress/lz4_raw.go b/compress/lz4_raw.go
@@ -9,11 +9,11 @@ import (
 )
 
 func init() {
-	lz4hc := lz4.CompressorHC{
-		Level: lz4.CompressionLevel(9),
-	}
 	compressors[parquet.CompressionCodec_LZ4_RAW] = &Compressor{
 		Compress: func(buf []byte) []byte {
+			lz4hc := lz4.CompressorHC{
+				Level: lz4.CompressionLevel(9),
+			}
 			res := make([]byte, lz4.CompressBlockBound(len(buf)))
 			count, _ := lz4hc.CompressBlock(buf, res)
 			return res[:count]