From 4554b3b33e716eb8e274c24a324cbf463b97fcb2 Mon Sep 17 00:00:00 2001 From: wangmm0220 Date: Wed, 4 Sep 2024 13:58:19 +0800 Subject: [PATCH] feat:[TD-30270] checkout subscribe logic if unsubscribe twice --- source/dnode/mnode/impl/src/mndConsumer.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/dnode/mnode/impl/src/mndConsumer.c b/source/dnode/mnode/impl/src/mndConsumer.c index 15ca11f938..c5a440b549 100644 --- a/source/dnode/mnode/impl/src/mndConsumer.c +++ b/source/dnode/mnode/impl/src/mndConsumer.c @@ -583,7 +583,7 @@ int32_t mndProcessSubscribeReq(SRpcMsg *pMsg) { MND_TMQ_RETURN_CHECK(mndAcquireConsumer(pMnode, subscribe.consumerId, &pConsumerTmp)); if (taosArrayGetSize(pConsumerTmp->assignedTopics) == 0){ mndReleaseConsumer(pMnode, pConsumerTmp); - return 0; + goto END; } mndReleaseConsumer(pMnode, pConsumerTmp); }