diff --git a/source/libs/sync/src/syncSnapshot.c b/source/libs/sync/src/syncSnapshot.c
index 38d3dc49951bd71cb6f427a96b5faab56553cbb4..9b099767c7202316245c47169c1c3277ea6c204a 100644
--- a/source/libs/sync/src/syncSnapshot.c
+++ b/source/libs/sync/src/syncSnapshot.c
@@ -116,6 +116,7 @@ void snapshotSenderStart(SSyncSnapshotSender *pSender) {
 
       // start again
       snapshotSenderDoStart(pSender);
+      pSender->start = true;
     } else {
       // current term, do nothing
       ASSERT(pSender->pSyncNode->pRaftStore->currentTerm == pSender->term);
@@ -297,6 +298,7 @@ void snapshotReceiverStart(SSyncSnapshotReceiver *pReceiver) {
   if (!(pReceiver->start)) {
     // start
     snapshotReceiverDoStart(pReceiver);
+    pReceiver->start = true;
 
   } else {
     // already start
@@ -309,6 +311,7 @@ void snapshotReceiverStart(SSyncSnapshotReceiver *pReceiver) {
 
     // start again
     snapshotReceiverDoStart(pReceiver);
+    pReceiver->start = true;
 
     ASSERT(0);
   }