From 2327cbb9b8dd4f03b7081cec4fdcb517d6f99dc4 Mon Sep 17 00:00:00 2001 From: dapan1121 <89396746@qq.com> Date: Wed, 27 Jan 2021 13:48:59 +0800 Subject: [PATCH] fix bug --- src/cq/src/cqMain.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/cq/src/cqMain.c b/src/cq/src/cqMain.c index 083028a32c..5203d66d16 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) { -- GitLab