From 0e6ea7af712f4c918df6b1a323b825ba1169f494 Mon Sep 17 00:00:00 2001
From: Benguang Zhao <bgzhao@taosdata.com>
Date: Tue, 26 Dec 2023 10:54:40 +0800
Subject: [PATCH] enh: check snapshot begin index for unexpected change in
 syncNodeOnSnapshotBegin

---
 source/libs/sync/src/syncSnapshot.c | 7 +++++++
 1 file changed, 7 insertions(+)

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) {