diff --git a/source/libs/sync/src/syncSnapshot.c b/source/libs/sync/src/syncSnapshot.c
index 2277b70c8f..10a8734617 100644
--- a/source/libs/sync/src/syncSnapshot.c
+++ b/source/libs/sync/src/syncSnapshot.c
@@ -806,6 +806,13 @@ static int32_t syncNodeOnSnapshotBegin(SSyncNode *pSyncNode, SyncSnapshotSend *p
     goto _SEND_REPLY;
   }
 
+  SyncIndex beginIndex = syncNodeGetSnapBeginIndex(pSyncNode);
+  if (pReceiver->snapshotParam.start != beginIndex) {
+    sRError(pReceiver, "snapshot begin index is changed unexpectedly. sver:%" PRId64 ", beginIndex:%" PRId64,
+            pReceiver->snapshotParam.start, beginIndex);
+    goto _SEND_REPLY;
+  }
+
   code = 0;
 _SEND_REPLY:
   if (code != 0 && terrno != 0) {