diff --git a/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteFunction.java b/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteFunction.java
index 6b5b9f939..5c9207a2f 100644
--- a/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteFunction.java
+++ b/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteFunction.java
@@ -207,6 +207,7 @@ public class StreamWriteFunction<K, I, O>
             TypeInformation.of(WriteMetadataEvent.class)
         ));
 
+    this.currentInstant = this.writeClient.getLastPendingInstant(this.actionType);
     if (context.isRestored()) {
       restoreWriteMetadata();
     } else {
@@ -214,7 +215,6 @@ public class StreamWriteFunction<K, I, O>
     }
     // blocks flushing until the coordinator starts a new instant
     this.confirming = true;
-    this.currentInstant = this.writeClient.getLastPendingInstant(this.actionType);
   }
 
   @Override