diff --git a/src/cq/src/cqMain.c b/src/cq/src/cqMain.c
index a5de27d7fc0cc3922456f5311834f2bd812f7a57..35384d27b716ca9ed2b09798698ff641dcdf67b6 100644
--- a/src/cq/src/cqMain.c
+++ b/src/cq/src/cqMain.c
@@ -217,6 +217,8 @@ void cqClose(void *handle) {
     
     taosRemoveRef(cqObjRef, rid);
   }
+  
+  tfree(pContext);
 }
 
 void cqStart(void *handle) {