MINOR: ZstdCompressionCodec should use decompressedSize to get error name (#619)

libenchao · web-flow · commit f1fd621f3ad5 · 2025-02-17T21:10:08.000-05:00
diff --git a/compression/src/main/java/org/apache/arrow/compression/ZstdCompressionCodec.java b/compression/src/main/java/org/apache/arrow/compression/ZstdCompressionCodec.java
@@ -68,7 +68,7 @@ protected ArrowBuf doDecompress(BufferAllocator allocator, ArrowBuf compressedBu
             compressedBuffer.writerIndex() - CompressionUtil.SIZE_OF_UNCOMPRESSED_LENGTH);
     if (Zstd.isError(decompressedSize)) {
       uncompressedBuffer.close();
-      throw new RuntimeException("Error decompressing: " + Zstd.getErrorName(decompressedLength));
+      throw new RuntimeException("Error decompressing: " + Zstd.getErrorName(decompressedSize));
     }
     if (decompressedLength != decompressedSize) {
       uncompressedBuffer.close();

Original file line number	Diff line number	Diff line change
`@@ -68,7 +68,7 @@ protected ArrowBuf doDecompress(BufferAllocator allocator, ArrowBuf compressedBu`
`68`	`68`	`compressedBuffer.writerIndex() - CompressionUtil.SIZE_OF_UNCOMPRESSED_LENGTH);`
`69`	`69`	`if (Zstd.isError(decompressedSize)) {`
`70`	`70`	`uncompressedBuffer.close();`
`71`		`- throw new RuntimeException("Error decompressing: " + Zstd.getErrorName(decompressedLength));`
	`71`	`+ throw new RuntimeException("Error decompressing: " + Zstd.getErrorName(decompressedSize));`
`72`	`72`	`}`
`73`	`73`	`if (decompressedLength != decompressedSize) {`
`74`	`74`	`uncompressedBuffer.close();`