diff --git a/hudi-flink/src/main/java/org/apache/hudi/operator/InstantGenerateOperator.java b/hudi-flink/src/main/java/org/apache/hudi/operator/InstantGenerateOperator.java
index 75c766837c0c6..103aef514d74e 100644
--- a/hudi-flink/src/main/java/org/apache/hudi/operator/InstantGenerateOperator.java
+++ b/hudi-flink/src/main/java/org/apache/hudi/operator/InstantGenerateOperator.java
@@ -78,7 +78,7 @@ public class InstantGenerateOperator extends AbstractStreamOperator<HoodieRecord
   private static final String DELIMITER = "_";
   private static final String INSTANT_MARKER_FOLDER_NAME = ".instant_marker";
   private transient boolean isMain = false;
-  private transient AtomicLong recordCounter = new AtomicLong(0);
+  private AtomicLong recordCounter = new AtomicLong(0);
   private StreamingRuntimeContext runtimeContext;
   private int indexOfThisSubtask;