提交 5257b77f 编写于 作者: S Shengliang Guan

fix: update telemetry and trans timer

上级 aca3d913
...@@ -114,7 +114,7 @@ static void *mndThreadFp(void *param) { ...@@ -114,7 +114,7 @@ static void *mndThreadFp(void *param) {
mndTtlTimer(pMnode); mndTtlTimer(pMnode);
} }
if (lastTime % (tsTransPullupInterval * 10) == 10) { if (lastTime % (tsTransPullupInterval * 10) == 1) {
mndPullupTrans(pMnode); mndPullupTrans(pMnode);
} }
...@@ -122,7 +122,7 @@ static void *mndThreadFp(void *param) { ...@@ -122,7 +122,7 @@ static void *mndThreadFp(void *param) {
mndCalMqRebalance(pMnode); mndCalMqRebalance(pMnode);
} }
if (lastTime % (tsTelemInterval * 10) == 30) { if (lastTime % (tsTelemInterval * 10) == 1) {
mndPullupTelem(pMnode); mndPullupTelem(pMnode);
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册