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