[hotfix] ZstdCompressionCodec should use decompressedSize to get error name (#422)

libenchao · web-flow · commit 7316e906791d · 2025-02-18T17:27:47.000+08:00
diff --git a/fluss-common/src/main/java/com/alibaba/fluss/compression/ZstdArrowCompressionCodec.java b/fluss-common/src/main/java/com/alibaba/fluss/compression/ZstdArrowCompressionCodec.java
@@ -77,7 +77,7 @@ protected ArrowBuf doDecompress(BufferAllocator allocator, ArrowBuf compressedBu
         if (Zstd.isError(decompressedSize)) {
             uncompressedBuffer.close();
             throw new RuntimeException(
-                    "Error decompressing: " + Zstd.getErrorName(decompressedLength));
+                    "Error decompressing: " + Zstd.getErrorName(decompressedSize));
         }
         if (decompressedLength != decompressedSize) {
             uncompressedBuffer.close();

Original file line number	Diff line number	Diff line change
`@@ -77,7 +77,7 @@ protected ArrowBuf doDecompress(BufferAllocator allocator, ArrowBuf compressedBu`
`77`	`77`	`if (Zstd.isError(decompressedSize)) {`
`78`	`78`	`uncompressedBuffer.close();`
`79`	`79`	`throw new RuntimeException(`
`80`		`- "Error decompressing: " + Zstd.getErrorName(decompressedLength));`
	`80`	`+ "Error decompressing: " + Zstd.getErrorName(decompressedSize));`
`81`	`81`	`}`
`82`	`82`	`if (decompressedLength != decompressedSize) {`
`83`	`83`	`uncompressedBuffer.close();`