diff --git a/source/dnode/vnode/src/vnd/vnodeSync.c b/source/dnode/vnode/src/vnd/vnodeSync.c
index 6c205b55220518a7a06bd91a951e9633068f51f1..ad6f153acaf06b5d44cf9a633e5bcc8b7f616770 100644
--- a/source/dnode/vnode/src/vnd/vnodeSync.c
+++ b/source/dnode/vnode/src/vnd/vnodeSync.c
@@ -515,6 +515,16 @@ void vnodeSyncPreClose(SVnode *pVnode) {
   vInfo("vgId:%d, pre close sync", pVnode->config.vgId);
   syncLeaderTransfer(pVnode->sync);
   syncPreStop(pVnode->sync);
+
+  while (!syncSnapshotRecving(pVnode->sync)) {
+    vInfo("vgId:%s, snapshot is recving");
+    taosMsleep(300);
+  }
+  while (!syncSnapshotSending(pVnode->sync)) {
+    vInfo("vgId:%s, snapshot is sending");
+    taosMsleep(300);
+  }
+
   taosThreadMutexLock(&pVnode->lock);
   if (pVnode->blocked) {
     vInfo("vgId:%d, post block after close sync", pVnode->config.vgId);