diff --git a/src/cq/src/cqMain.c b/src/cq/src/cqMain.c index cc1628c968..c2df0d36b2 100644 --- a/src/cq/src/cqMain.c +++ b/src/cq/src/cqMain.c @@ -227,6 +227,7 @@ void cqClose(void *handle) { taosRemoveRef(cqObjRef, rid); } + freeSCqContext(pContext); }