diff --git a/src/sync/src/syncMain.c b/src/sync/src/syncMain.c index 17815c93aaf427440f2f0bfc2fe34351394076a8..a538b4db87d870d187473651e80baa3922bbb3c7 100644 --- a/src/sync/src/syncMain.c +++ b/src/sync/src/syncMain.c @@ -137,6 +137,7 @@ void syncCleanUp() { } taosCloseRef(tsSyncRefId); + tsSyncRefId = -1; sInfo("sync module is cleaned up"); } @@ -1205,6 +1206,8 @@ static void syncMonitorFwdInfos(void *param, void *tmrId) { pNode->pFwdTimer = taosTmrStart(syncMonitorFwdInfos, 300, pNode, syncTmrCtrl); } + + taosReleaseRef(tsSyncRefId, pNode); } static int32_t syncForwardToPeerImpl(SSyncNode *pNode, void *data, void *mhandle, int qtype) {