diff --git a/source/dnode/mnode/impl/src/mndSubscribe.c b/source/dnode/mnode/impl/src/mndSubscribe.c index 58c89d76aa41542d4138ed4b638333edc74ef947..ffb46e5f1b7e085d00e9a4f69e667c44a8db9fa7 100644 --- a/source/dnode/mnode/impl/src/mndSubscribe.c +++ b/source/dnode/mnode/impl/src/mndSubscribe.c @@ -782,6 +782,7 @@ SUB_DECODE_OVER: return NULL; } + mTrace("subscribe:%s, decode from raw:%p, row:%p", pSub->key, pRaw, pSub); return pRow; } @@ -928,6 +929,7 @@ int32_t mndDropSubByTopic(SMnode *pMnode, STrans *pTrans, const char *topicName) action.msgType = TDMT_VND_TMQ_DELETE_SUB; if (mndTransAppendRedoAction(pTrans, &action) != 0) { taosMemoryFree(pReq); + sdbRelease(pSdb, pSub); return -1; } } @@ -936,6 +938,8 @@ int32_t mndDropSubByTopic(SMnode *pMnode, STrans *pTrans, const char *topicName) sdbRelease(pSdb, pSub); goto END; } + + sdbRelease(pSdb, pSub); } code = 0; diff --git a/tests/parallel_test/cases.task b/tests/parallel_test/cases.task index 19dcec442a075ff511393e7b01ad6aa18d15dadd..e4bd7d6c51e7a10298b32bda11c58907fb1ccaa0 100644 --- a/tests/parallel_test/cases.task +++ b/tests/parallel_test/cases.task @@ -670,7 +670,7 @@ ,,,system-test,python3 test.py -f 6-cluster/vnode/4dnode1mnode_basic_replica3_vgroups.py -N 4 -M 1 ,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/create_wrong_topic.py ,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/dropDbR3ConflictTransaction.py -N 3 -,,,system-test,python3 ./test.py -f 7-tmq/basic5.py +,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/basic5.py ,,,system-test,python3 ./test.py -f 7-tmq/subscribeDb.py ,,,system-test,python3 ./test.py -f 7-tmq/subscribeDb0.py ,,,system-test,python3 ./test.py -f 7-tmq/subscribeDb1.py