From 59d8f7d10fa8ad0d0bb1920182fe1fdbe41303eb Mon Sep 17 00:00:00 2001 From: wangmm0220 Date: Mon, 18 Sep 2023 17:55:00 +0800 Subject: [PATCH] fix:return in progress in drop consumer group --- source/dnode/mnode/impl/src/mndSubscribe.c | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/source/dnode/mnode/impl/src/mndSubscribe.c b/source/dnode/mnode/impl/src/mndSubscribe.c index 3131112c9a..17c63529ed 100644 --- a/source/dnode/mnode/impl/src/mndSubscribe.c +++ b/source/dnode/mnode/impl/src/mndSubscribe.c @@ -875,7 +875,11 @@ end: mndReleaseSubscribe(pMnode, pSub); mndTransDrop(pTrans); - return code; + if (code != 0) { + mError("cgroup %s on topic:%s, failed to drop", dropReq.cgroup, dropReq.topic); + return code; + } + return TSDB_CODE_ACTION_IN_PROGRESS; } void mndCleanupSubscribe(SMnode *pMnode) {}