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

fix:[TD-30915]tmq exit elegantly

This commit is contained in:
wangmm0220 2024-07-08 14:28:27 +08:00
parent 24b3bcaa9f
commit e14d11c78a
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
source/client/src/clientTmq.c
View File

@ -1063,7 +1063,6 @@ void tmqFreeImpl(void* handle) {
taosArrayDestroyEx(tmq->clientTopics, freeClientVgImpl); taosArrayDestroyEx(tmq->clientTopics, freeClientVgImpl);
taos_close_internal(tmq->pTscObj); taos_close_internal(tmq->pTscObj);
taosMemoryFree(tmq);
if(tmq->commitTimer) { if(tmq->commitTimer) {
taosTmrStopA(tmq->commitTimer); taosTmrStopA(tmq->commitTimer);
@ -1077,6 +1076,8 @@ void tmqFreeImpl(void* handle) {
taosTmrStopA(tmq->hbLiveTimer); taosTmrStopA(tmq->hbLiveTimer);
tmq->hbLiveTimer = NULL; tmq->hbLiveTimer = NULL;
} }
taosMemoryFree(tmq);
tscDebug("consumer:0x%" PRIx64 " closed", id); tscDebug("consumer:0x%" PRIx64 " closed", id);
} }