diff --git a/source/libs/sync/src/syncSnapshot.c b/source/libs/sync/src/syncSnapshot.c
index cbdcbef3a6..8e186af51f 100644
--- a/source/libs/sync/src/syncSnapshot.c
+++ b/source/libs/sync/src/syncSnapshot.c
@@ -874,7 +874,7 @@ static int32_t syncSnapBufferRecv(SSyncSnapshotReceiver *pReceiver, SyncSnapshot
   }
 
   for (int64_t seq = pRcvBuf->cursor + 1; seq < pRcvBuf->end; ++seq) {
-    if (pRcvBuf->entries[seq]) {
+    if (pRcvBuf->entries[seq % pRcvBuf->size]) {
       pRcvBuf->cursor = seq;
     } else {
       break;