xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix:case error

This commit is contained in:
wangmm0220 2024-03-14 14:27:13 +08:00
parent f27becb76a
commit c866c9ad02
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
source/dnode/mnode/impl/src/mndSubscribe.c
View File

@ -935,8 +935,7 @@ static int32_t mndDropConsumerByGroup(SMnode *pMnode, STrans *pTrans, char *cgro
break; break;
} }
if (strcmp(cgroup, pConsumer->cgroup) == 0 && taosArrayGetSize(pConsumer->assignedTopics) == 1 && if (strcmp(cgroup, pConsumer->cgroup) == 0 && taosArrayGetSize(pConsumer->currentTopics) == 0) {
strcmp(topic, taosArrayGetP(pConsumer->assignedTopics, 0)) == 0) {
int32_t code = mndSetConsumerDropLogs(pTrans, pConsumer); int32_t code = mndSetConsumerDropLogs(pTrans, pConsumer);
if (code != 0) { if (code != 0) {
sdbRelease(pMnode->pSdb, pConsumer); sdbRelease(pMnode->pSdb, pConsumer);