diff --git a/src/balance/src/balance.c b/src/balance/src/balance.c index 0d4da965e2c1778b5d7e55cf7becf0bf46e5b681..8701b012ff8660c4bd568e00ce10db614da8dfa3 100644 --- a/src/balance/src/balance.c +++ b/src/balance/src/balance.c @@ -959,9 +959,14 @@ static void balanceMonitorDnodeModule() { mLInfo("dnode:%d, numOfMnodes:%d expect:%d, create mnode in this dnode", pDnode->dnodeId, numOfMnodes, tsNumOfMnodes); mnodeCreateMnode(pDnode->dnodeId, pDnode->dnodeEp, true); - + +#if 0 // Only create one mnode each time return; +#else + numOfMnodes = mnodeGetMnodesNum(); + if (numOfMnodes >= tsNumOfMnodes) return; +#endif } }