From 1b93f980e874476c0b35f5ba5461659d233924db Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Mon, 6 Mar 2023 21:33:31 +0800 Subject: [PATCH] refactor: do some internal refactor. --- source/dnode/mnode/impl/src/mndSubscribe.c | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/source/dnode/mnode/impl/src/mndSubscribe.c b/source/dnode/mnode/impl/src/mndSubscribe.c index 5ad12a6450..6368472dc9 100644 --- a/source/dnode/mnode/impl/src/mndSubscribe.c +++ b/source/dnode/mnode/impl/src/mndSubscribe.c @@ -357,11 +357,12 @@ static int32_t mndDoRebalance(SMnode *pMnode, const SMqRebInputObj *pInput, SMqR if (numOfFinal) { minVgCnt = totalVgNum / numOfFinal; imbConsumerNum = totalVgNum % numOfFinal; + mInfo("sub:%s mq re-balance %d consumers: at least %d vgs each, %d consumers has 1 more vgroups than avg value", + pSubKey, numOfFinal, minVgCnt, imbConsumerNum); + } else { + mInfo("sub:%s no consumer subscribe this topic", pSubKey); } - mInfo("sub:%s mq re-balance %d consumers: at least %d vgs each, %d consumers has 1 more vgroups than avg value", - pSubKey, numOfFinal, minVgCnt, imbConsumerNum); - // 5. first scan: remove vgroups from te consumers, who have more vgroups than the threashold value that is // minVgCnt, and then put them into the recycled hash list transferVgroupsForConsumers(pOutput, pHash, minVgCnt, imbConsumerNum);