This is an automated email from the ASF dual-hosted git repository.

lidavidm pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/arrow-java.git


The following commit(s) were added to refs/heads/main by this push:
     new f1fd621f MINOR: ZstdCompressionCodec should use decompressedSize to 
get error name (#619)
f1fd621f is described below

commit f1fd621f3ad5726677a8aac1b8a7189432372865
Author: Benchao Li <[email protected]>
AuthorDate: Tue Feb 18 10:10:08 2025 +0800

    MINOR: ZstdCompressionCodec should use decompressedSize to get error name 
(#619)
---
 .../main/java/org/apache/arrow/compression/ZstdCompressionCodec.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/compression/src/main/java/org/apache/arrow/compression/ZstdCompressionCodec.java
 
b/compression/src/main/java/org/apache/arrow/compression/ZstdCompressionCodec.java
index 6e48aae7..46b1e223 100644
--- 
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 @@ public class ZstdCompressionCodec extends 
AbstractCompressionCodec {
             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();

Reply via email to