diff --git a/source/client/src/clientStmt.c b/source/client/src/clientStmt.c index b16d1e8aac..165c7b8bfb 100644 --- a/source/client/src/clientStmt.c +++ b/source/client/src/clientStmt.c @@ -53,7 +53,6 @@ bool stmtDequeue(STscStmt* pStmt, SStmtQNode** param) { } } if (pStmt->queue.stopQueue) { - (void)taosThreadMutexUnlock(&pStmt->queue.mutex); return false; } SStmtQNode* orig = pStmt->queue.head; diff --git a/source/client/src/clientStmt2.c b/source/client/src/clientStmt2.c index bc8b03ffd4..75d763ec71 100644 --- a/source/client/src/clientStmt2.c +++ b/source/client/src/clientStmt2.c @@ -53,7 +53,6 @@ static bool stmtDequeue(STscStmt2* pStmt, SStmtQNode** param) { } } if (pStmt->queue.stopQueue) { - (void)taosThreadMutexUnlock(&pStmt->queue.mutex); return false; } SStmtQNode* orig = pStmt->queue.head;