diff --git a/source/client/src/clientTmq.c b/source/client/src/clientTmq.c index e137bd3ee3..4d24548a31 100644 --- a/source/client/src/clientTmq.c +++ b/source/client/src/clientTmq.c @@ -1615,6 +1615,7 @@ static void tmqMgmtInit(void) { if (taosThreadMutexInit(&tmqMgmt.lock, NULL) != 0){ goto END; } + return; END: tmqInitRes = terrno;