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();