From d129d3f34a4d56495b1c3bed3b519455d17a8f22 Mon Sep 17 00:00:00 2001 From: Benchao Li Date: Mon, 17 Feb 2025 20:47:47 +0800 Subject: [PATCH] MINOR: ZstdCompressionCodec should use decompressedSize to get error name --- .../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 6e48aae71f..46b1e223a4 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 @@ 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();