diff --git a/source/libs/sync/src/syncReplication.c b/source/libs/sync/src/syncReplication.c
index 29370fd4a5ec20facd486824ab7aac92e807b25e..24f75de5d36b89cdbff84aa7846ff972259a882b 100644
--- a/source/libs/sync/src/syncReplication.c
+++ b/source/libs/sync/src/syncReplication.c
@@ -199,7 +199,6 @@ int32_t syncNodeAppendEntriesPeersSnapshot2(SSyncNode* pSyncNode) {
 
     // send msg
     syncNodeAppendEntriesBatch(pSyncNode, pDestId, pMsg);
-    syncAppendEntriesBatchDestroy(pMsg);
 
     // speed up
     if (pMsg->dataCount > 0 && pSyncNode->commitIndex - pMsg->prevLogIndex > SYNC_SLOW_DOWN_RANGE) {
@@ -216,6 +215,8 @@ int32_t syncNodeAppendEntriesPeersSnapshot2(SSyncNode* pSyncNode) {
       } while (0);
 #endif
     }
+
+    syncAppendEntriesBatchDestroy(pMsg);
   }
 
   return ret;