diff --git a/src/cq/src/cqMain.c b/src/cq/src/cqMain.c index 083028a32cb1772771579219d4fe776914696fd0..5203d66d16b1e77c852227516504c513eb978758 100644 --- a/src/cq/src/cqMain.c +++ b/src/cq/src/cqMain.c @@ -305,9 +305,9 @@ void cqDrop(void *handle) { pObj->tmrId = 0; } - taosReleaseRef(cqObjRef, pObj->rid); - pthread_mutex_unlock(&pContext->mutex); + + taosReleaseRef(cqObjRef, pObj->rid); } static void doCreateStream(void *param, TAOS_RES *result, int32_t code) {