diff --git a/source/libs/sync/inc/syncInt.h b/source/libs/sync/inc/syncInt.h
index 41463e2f7f4587f0027f41a3eef9492e8a4f8386..fbe31ef03157f3ace8acadb9faf2bfa3e01896fb 100644
--- a/source/libs/sync/inc/syncInt.h
+++ b/source/libs/sync/inc/syncInt.h
@@ -162,8 +162,8 @@ typedef struct SSyncNode {
 
   // restore state
   // sem_t      restoreSem;
-  bool                   restoreFinish;
-  SSnapshot*             pSnapshot;
+  bool restoreFinish;
+  // SSnapshot*             pSnapshot;
   SSyncSnapshotSender*   senders[TSDB_MAX_REPLICA];
   SSyncSnapshotReceiver* receivers[TSDB_MAX_REPLICA];
 
diff --git a/source/libs/sync/src/syncAppendEntries.c b/source/libs/sync/src/syncAppendEntries.c
index fc20d6dd876f2994efd2635ee638706b3549bb68..967ed5a00d05009a5b9ea1d9292f46e20b3f22ff 100644
--- a/source/libs/sync/src/syncAppendEntries.c
+++ b/source/libs/sync/src/syncAppendEntries.c
@@ -335,8 +335,12 @@ int32_t syncNodeOnAppendEntriesCb(SSyncNode* ths, SyncAppendEntries* pMsg) {
                 cbMeta.currentTerm = ths->pRaftStore->currentTerm;
                 cbMeta.flag = 0x11;
 
+                SSnapshot snapshot;
+                ASSERT(ths->pFsm->FpGetSnapshot != NULL);
+                ths->pFsm->FpGetSnapshot(ths->pFsm, &snapshot);
+
                 bool needExecute = true;
-                if (ths->pSnapshot != NULL && cbMeta.index <= ths->pSnapshot->lastApplyIndex) {
+                if (cbMeta.index <= snapshot.lastApplyIndex) {
                   needExecute = false;
                 }
 
diff --git a/source/libs/sync/src/syncCommit.c b/source/libs/sync/src/syncCommit.c
index 4a1a40a2d7ddd47d9d6ec30a683f284dacc70fa7..b683ab12b402e964a1c17d1b25e33e5997b1718d 100644
--- a/source/libs/sync/src/syncCommit.c
+++ b/source/libs/sync/src/syncCommit.c
@@ -113,8 +113,12 @@ void syncMaybeAdvanceCommitIndex(SSyncNode* pSyncNode) {
             cbMeta.currentTerm = pSyncNode->pRaftStore->currentTerm;
             cbMeta.flag = 0x1;
 
+            SSnapshot snapshot;
+            ASSERT(pSyncNode->pFsm->FpGetSnapshot != NULL);
+            pSyncNode->pFsm->FpGetSnapshot(pSyncNode->pFsm, &snapshot);
+
             bool needExecute = true;
-            if (pSyncNode->pSnapshot != NULL && cbMeta.index <= pSyncNode->pSnapshot->lastApplyIndex) {
+            if (cbMeta.index <= snapshot.lastApplyIndex) {
               needExecute = false;
             }
 
diff --git a/source/libs/sync/src/syncMain.c b/source/libs/sync/src/syncMain.c
index 947e952276aa5768c77e695b8ca62a398d905305..65101e0215c8daf496024c7f170d78f5777a9727 100644
--- a/source/libs/sync/src/syncMain.c
+++ b/source/libs/sync/src/syncMain.c
@@ -575,11 +575,12 @@ SSyncNode* syncNodeOpen(const SSyncInfo* pOldSyncInfo) {
 
   // restore state
   pSyncNode->restoreFinish = false;
-  pSyncNode->pSnapshot = NULL;
-  if (pSyncNode->pFsm->FpGetSnapshot != NULL) {
-    pSyncNode->pSnapshot = taosMemoryMalloc(sizeof(SSnapshot));
-    pSyncNode->pFsm->FpGetSnapshot(pSyncNode->pFsm, pSyncNode->pSnapshot);
-  }
+
+  // pSyncNode->pSnapshot = NULL;
+  // if (pSyncNode->pFsm->FpGetSnapshot != NULL) {
+  //   pSyncNode->pSnapshot = taosMemoryMalloc(sizeof(SSnapshot));
+  //   pSyncNode->pFsm->FpGetSnapshot(pSyncNode->pFsm, pSyncNode->pSnapshot);
+  // }
   // tsem_init(&(pSyncNode->restoreSem), 0, 0);
 
   // start in syncNodeStart
@@ -673,9 +674,11 @@ void syncNodeClose(SSyncNode* pSyncNode) {
     taosMemoryFree(pSyncNode->pFsm);
   }
 
+  /*
   if (pSyncNode->pSnapshot != NULL) {
     taosMemoryFree(pSyncNode->pSnapshot);
   }
+  */
 
   // tsem_destroy(&pSyncNode->restoreSem);