fix: mem leak
This commit is contained in:
parent
461dbe752d
commit
1e17f1d482
|
@ -1891,9 +1891,6 @@ int32_t tmq_consumer_close(tmq_t* tmq) {
|
||||||
}
|
}
|
||||||
|
|
||||||
tmq_list_destroy(lst);
|
tmq_list_destroy(lst);
|
||||||
|
|
||||||
/*return rsp;*/
|
|
||||||
return 0;
|
|
||||||
}
|
}
|
||||||
taosRemoveRef(tmqMgmt.rsetId, tmq->refId);
|
taosRemoveRef(tmqMgmt.rsetId, tmq->refId);
|
||||||
return 0;
|
return 0;
|
||||||
|
|
Loading…
Reference in New Issue