diff --git a/source/dnode/mnode/impl/src/mndMain.c b/source/dnode/mnode/impl/src/mndMain.c index b945a2551cfb2d74e346de99ee2af73bba6121b4..e6b6aaacf19a534221850ceef32fe936dcff347d 100644 --- a/source/dnode/mnode/impl/src/mndMain.c +++ b/source/dnode/mnode/impl/src/mndMain.c @@ -127,15 +127,15 @@ static void *mndThreadFp(void *param) { mndPullupTtl(pMnode); } - if (sec % tsTransPullupInterval * 10 == 0) { + if (sec % tsTransPullupInterval == 0) { mndPullupTrans(pMnode); } - if (sec % tsMqRebalanceInterval * 10 == 0) { + if (sec % tsMqRebalanceInterval == 0) { mndCalMqRebalance(pMnode); } - if (sec % tsTelemInterval * 10 == (MIN(60, (tsTelemInterval - 1)))) { + if (sec % tsTelemInterval == (MIN(60, (tsTelemInterval - 1)))) { mndPullupTelem(pMnode); }