From 858c034cdc6bfad50cd088bc77203b13b7a6f3b9 Mon Sep 17 00:00:00 2001
From: Shengliang Guan <slguan@taosdata.com>
Date: Wed, 18 Nov 2020 06:05:06 +0000
Subject: [PATCH] TD-2083

---
 src/sync/src/syncMain.c | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/src/sync/src/syncMain.c b/src/sync/src/syncMain.c
index 4f9d58f0a0..7df7fd37e0 100644
--- a/src/sync/src/syncMain.c
+++ b/src/sync/src/syncMain.c
@@ -1222,9 +1222,12 @@ static void syncMonitorFwdInfos(void *param, void *tmrId) {
       pthread_mutex_unlock(&(pNode->mutex));
     }
 
-    taosReleaseRef(tsSyncRefId, rid);
+    pNode->pFwdTimer = taosTmrStart(syncMonitorFwdInfos, 300, (void *)pNode->rid, tsSyncTmrCtrl);
   }
 
+  taosReleaseRef(tsSyncRefId, rid);
+}
+
 static int32_t syncForwardToPeerImpl(SSyncNode *pNode, void *data, void *mhandle, int32_t qtype) {
   SSyncPeer *pPeer;
   SSyncHead *pSyncHead;
-- 
GitLab