Use NoFinalizer classes for ZSTD

ydb-platform · Oct 21, 2024 · 84e9845 · 84e9845
1 parent 81fdf62
commit 84e9845
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/topic/src/main/java/tech/ydb/topic/utils/Encoder.java b/topic/src/main/java/tech/ydb/topic/utils/Encoder.java
@@ -8,8 +8,8 @@
 import java.util.zip.GZIPInputStream;
 import java.util.zip.GZIPOutputStream;
 
-import com.github.luben.zstd.ZstdInputStream;
-import com.github.luben.zstd.ZstdOutputStream;
+import com.github.luben.zstd.ZstdInputStreamNoFinalizer;
+import com.github.luben.zstd.ZstdOutputStreamNoFinalizer;
 import org.anarres.lzo.LzoAlgorithm;
 import org.anarres.lzo.LzoCompressor;
 import org.anarres.lzo.LzoLibrary;
@@ -61,7 +61,7 @@ private static OutputStream makeOutputStream(Codec codec,
             case GZIP:
                 return new GZIPOutputStream(byteArrayOutputStream);
             case ZSTD:
-                return new ZstdOutputStream(byteArrayOutputStream);
+                return new ZstdOutputStreamNoFinalizer(byteArrayOutputStream);
             case LZOP:
                 LzoCompressor lzoCompressor = LzoLibrary.getInstance().newCompressor(LzoAlgorithm.LZO1X, null);
                 return new LzoOutputStream(byteArrayOutputStream, lzoCompressor);
@@ -77,7 +77,7 @@ private static InputStream makeInputStream(Codec codec,
             case GZIP:
                 return new GZIPInputStream(byteArrayInputStream);
             case ZSTD:
-                return new ZstdInputStream(byteArrayInputStream);
+                return new ZstdInputStreamNoFinalizer(byteArrayInputStream);
             case LZOP:
                 return new LzopInputStream(byteArrayInputStream);
             case CUSTOM: