diff --git a/source/client/src/clientTmq.c b/source/client/src/clientTmq.c index 4662c31fb1..a2c8bfa351 100644 --- a/source/client/src/clientTmq.c +++ b/source/client/src/clientTmq.c @@ -1612,16 +1612,7 @@ static void tmqMgmtInit(void) { goto END; } - TdThreadMutexAttr attr = {0}; - if (taosThreadMutexAttrInit(&attr) != 0){ - goto END; - } - - if (taosThreadMutexInit(&tmqMgmt.lock, &attr) != 0){ - goto END; - } - - if (taosThreadMutexAttrDestroy(&attr) != 0){ + if (taosThreadMutexInit(&tmqMgmt.lock, NULL) != 0){ goto END; }