From fe5d2e7f53eb36d9e35acd8d944e59d988dba475 Mon Sep 17 00:00:00 2001
From: swuferhong <337361684@qq.com>
Date: Thu, 22 Jul 2021 16:35:07 +0800
Subject: [PATCH] [HUDI-2206] Fix checkpoint blocked because
 getLastPendingInstant() action after than restoreWriteMetadata() action
 (#3326)

---
 .../src/main/java/org/apache/hudi/sink/StreamWriteFunction.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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