diff --git a/src/main/java/io/airlift/compress/zstd/ZstdDecompressor.java b/src/main/java/io/airlift/compress/zstd/ZstdDecompressor.java
index 35744644..bf415e57 100644
--- a/src/main/java/io/airlift/compress/zstd/ZstdDecompressor.java
+++ b/src/main/java/io/airlift/compress/zstd/ZstdDecompressor.java
@@ -25,8 +25,6 @@
 public class ZstdDecompressor
         implements Decompressor
 {
-    private final ZstdFrameDecompressor decompressor = new ZstdFrameDecompressor();
-
     @Override
     public int decompress(byte[] input, int inputOffset, int inputLength, byte[] output, int outputOffset, int maxOutputLength)
             throws MalformedInputException
@@ -36,7 +34,7 @@ public int decompress(byte[] input, int inputOffset, int inputLength, byte[] out
         long outputAddress = ARRAY_BYTE_BASE_OFFSET + outputOffset;
         long outputLimit = outputAddress + maxOutputLength;
 
-        return decompressor.decompress(input, inputAddress, inputLimit, output, outputAddress, outputLimit);
+        return new ZstdFrameDecompressor().decompress(input, inputAddress, inputLimit, output, outputAddress, outputLimit);
     }
 
     @Override