fix:[TD-33272]add test case
This commit is contained in:
parent
e65a3802a2
commit
20c1e28d0c
|
@ -151,10 +151,8 @@ void tqClose(STQ* pTq) {
|
||||||
taosHashCleanup(pTq->pOffset);
|
taosHashCleanup(pTq->pOffset);
|
||||||
taosMemoryFree(pTq->path);
|
taosMemoryFree(pTq->path);
|
||||||
tqMetaClose(pTq);
|
tqMetaClose(pTq);
|
||||||
|
|
||||||
streamMetaClose(pTq->pStreamMeta);
|
|
||||||
|
|
||||||
qDebug("vgId:%d end to close tq", pTq->pStreamMeta != NULL ? pTq->pStreamMeta->vgId : -1);
|
qDebug("vgId:%d end to close tq", pTq->pStreamMeta != NULL ? pTq->pStreamMeta->vgId : -1);
|
||||||
|
streamMetaClose(pTq->pStreamMeta);
|
||||||
taosMemoryFree(pTq);
|
taosMemoryFree(pTq);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue