address comments

Author: swuferhong

fluss-common/pom.xml

@@ -70,7 +70,7 @@
         <dependency>
             <groupId>com.github.luben</groupId>
             <artifactId>zstd-jni</artifactId>
-            <version> 1.5.7-1</version>
+            <version>1.5.7-1</version>
         </dependency>
 
         <!-- RocksDB dependencies -->

fluss-common/src/main/java/com/alibaba/fluss/compression/ZstdArrowCompressionCodec.java

@@ -54,11 +54,10 @@ protected ArrowBuf doCompress(BufferAllocator allocator, ArrowBuf uncompressedBu
                 compressedBuffer.nioBuffer(
                         CompressionUtil.SIZE_OF_UNCOMPRESSED_LENGTH, (int) maxSize);
 
-        // The reason why we use Zstd.compressDirectByteBuffer(ByteBuffer dst, int dstOffset, int
-        // dstSize, ByteBuffer src, int srcOffset, int srcSize, int level) instead of
-        // Zstd.compressUnsafe(long dst, long dstSize, long src, long srcSize, int level) used in
-        // arrow-java here is that compressUnsafe() may encounter occasional data corruption issues
-        // when dealing with large volumes of data, and the cause has not yet been determined.
+        // The reason why we use Zstd.compressDirectByteBuffer instead of Zstd.compressUnsafe used
+        // in arrow-java here is that compressUnsafe() may encounter occasional data corruption
+        // issues when dealing with large volumes of data, and the cause has not yet been
+        // determined.
         long bytesWritten =
                 Zstd.compressDirectByteBuffer(
                         compressedDirectBuffer,