diff --git a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/io/compress/zstd/ZStandardCompressor.java b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/io/compress/zstd/ZStandardCompressor.java
index 716a19886f8..7445502c989 100644
--- a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/io/compress/zstd/ZStandardCompressor.java
+++ b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/io/compress/zstd/ZStandardCompressor.java
@@ -49,7 +49,7 @@ public class ZStandardCompressor implements Compressor {
   private int uncompressedDirectBufOff = 0, uncompressedDirectBufLen = 0;
   private boolean keepUncompressedBuf = false;
   private ByteBuffer compressedDirectBuf = null;
-  private boolean finished;
+  private boolean finish, finished;
   private long bytesRead = 0;
   private long bytesWritten = 0;
 
@@ -180,6 +180,7 @@ public boolean needsInput() {
 
   @Override
   public void finish() {
+    finish = true;
   }
 
   @Override
@@ -265,6 +266,7 @@ public long getBytesRead() {
   public void reset() {
     checkStream();
     init(level, stream);
+    finish = false;
     finished = false;
     bytesRead = 0;
     bytesWritten = 0;