diff --git a/source/dnode/mnode/impl/src/mndMain.c b/source/dnode/mnode/impl/src/mndMain.c index ee73b5dad9..b8ea6b2c28 100644 --- a/source/dnode/mnode/impl/src/mndMain.c +++ b/source/dnode/mnode/impl/src/mndMain.c @@ -114,7 +114,7 @@ static void *mndThreadFp(void *param) { mndTtlTimer(pMnode); } - if (lastTime % (tsTransPullupInterval * 10) == 10) { + if (lastTime % (tsTransPullupInterval * 10) == 1) { mndPullupTrans(pMnode); } @@ -122,7 +122,7 @@ static void *mndThreadFp(void *param) { mndCalMqRebalance(pMnode); } - if (lastTime % (tsTelemInterval * 10) == 30) { + if (lastTime % (tsTelemInterval * 10) == 1) { mndPullupTelem(pMnode); }