use safeDecompressor for lz4

Author: JingsongLi

paimon-common/src/main/java/org/apache/paimon/compression/Lz4BlockDecompressor.java

@@ -20,7 +20,7 @@
 
 import net.jpountz.lz4.LZ4Exception;
 import net.jpountz.lz4.LZ4Factory;
-import net.jpountz.lz4.LZ4FastDecompressor;
+import net.jpountz.lz4.LZ4SafeDecompressor;
 
 import static org.apache.paimon.compression.CompressorUtils.HEADER_LENGTH;
 import static org.apache.paimon.compression.CompressorUtils.readIntLE;
@@ -34,10 +34,10 @@
  */
 public class Lz4BlockDecompressor implements BlockDecompressor {
 
-    private final LZ4FastDecompressor decompressor;
+    private final LZ4SafeDecompressor decompressor;
 
     public Lz4BlockDecompressor() {
-        this.decompressor = LZ4Factory.fastestInstance().fastDecompressor();
+        this.decompressor = LZ4Factory.fastestInstance().safeDecompressor();
     }
 
     @Override
@@ -58,7 +58,7 @@ public int decompress(byte[] src, int srcOff, int srcLen, byte[] dst, int dstOff
 
         try {
             final int compressedLen2 =
-                    decompressor.decompress(src, srcOff + HEADER_LENGTH, dst, dstOff, originalLen);
+                    decompressor.decompress(src, srcOff + HEADER_LENGTH, originalLen, dst, dstOff);
             if (compressedLen != compressedLen2) {
                 throw new BufferDecompressionException("Input is corrupted");
             }