opti:tmq logic

2024-03-14 00:08:56 +08:00 · 2024-03-14 00:08:56 +08:00 · f27becb76a
parent 5a5bf29acb
commit f27becb76a
1 changed files with 1 additions and 0 deletions
--- a/source/dnode/mnode/impl/src/mndConsumer.c
+++ b/source/dnode/mnode/impl/src/mndConsumer.c
@ -642,6 +642,7 @@ static SMqConsumerObj* buildSubConsumer(SMnode *pMnode, SCMSubscribeReq *subscri
      goto _over;
    }
  }
+  mndReleaseConsumer(pMnode, pExistedConsumer);
  return pConsumerNew;

 _over: