diff --git a/src/cq/src/cqMain.c b/src/cq/src/cqMain.c
index 908042ba0629b7df899b645bdeb9400524768c13..a5de27d7fc0cc3922456f5311834f2bd812f7a57 100644
--- a/src/cq/src/cqMain.c
+++ b/src/cq/src/cqMain.c
@@ -215,7 +215,7 @@ void cqClose(void *handle) {
     
     pthread_mutex_unlock(&pContext->mutex);
     
-    taosReleaseRef(cqObjRef, rid);
+    taosRemoveRef(cqObjRef, rid);
   }
 }