From 7aa03633a7b2e2249a4099efc41317c6b358350e Mon Sep 17 00:00:00 2001
From: Benchao Li <libenchao.bruce@bytedance.com>
Date: Tue, 18 Feb 2025 13:05:02 +0800
Subject: [PATCH] [hotfix] ZstdCompressionCodec should use decompressedSize to
 get error name

This has been fixed in https://github.com/apache/arrow-java/pull/619
---
 .../alibaba/fluss/compression/ZstdArrowCompressionCodec.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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
index 1009f14183..7457b2ccc4 100644
--- 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();