diff --git a/src/sync/src/syncRestore.c b/src/sync/src/syncRestore.c
index 4c2444caa008f4198c7f0721cb4e6956cdc7f89d..22d0a2758131f3880adc63f3777528c8e3d06ff9 100644
--- a/src/sync/src/syncRestore.c
+++ b/src/sync/src/syncRestore.c
@@ -238,7 +238,7 @@ static int32_t syncRestoreDataStepByStep(SSyncPeer *pPeer) {
 
   (*pNode->stopSyncFileFp)(pNode->vgId, fversion);
   nodeVersion = fversion;
-  (*pNode->resetVersionFp)(pNode->vgId, fversion);
+  if (pNode->resetVersionFp) (*pNode->resetVersionFp)(pNode->vgId, fversion);
 
   sInfo("%s, start to restore wal, fver:%" PRIu64, pPeer->id, nodeVersion);
   uint64_t wver = 0;