diff --git a/source/dnode/mgmt/mgmt_vnode/src/vmHandle.c b/source/dnode/mgmt/mgmt_vnode/src/vmHandle.c
index 834b43c380..7e950ef1be 100644
--- a/source/dnode/mgmt/mgmt_vnode/src/vmHandle.c
+++ b/source/dnode/mgmt/mgmt_vnode/src/vmHandle.c
@@ -415,14 +415,24 @@ int32_t vmProcessCreateVnodeReq(SVnodeMgmt *pMgmt, SRpcMsg *pMsg) {
     goto _OVER;
   }
 
-  taosThreadMutexLock(&pMgmt->createLock);
+  code = taosThreadMutexLock(&pMgmt->createLock);
+  if (code != 0) {
+    dError("vgId:%d, failed to lock since %s", req.vgId, tstrerror(code));
+    goto _OVER;
+  }
   code = vmWriteVnodeListToFile(pMgmt);
   if (code != 0) {
     code = terrno != 0 ? terrno : code;
-    taosThreadMutexUnlock(&pMgmt->createLock);
+    int32_t ret = taosThreadMutexUnlock(&pMgmt->createLock);
+    if (ret != 0) {
+      dError("vgId:%d, failed to unlock since %s", req.vgId, tstrerror(ret));
+    }
     goto _OVER;
   }
-  taosThreadMutexUnlock(&pMgmt->createLock);
+  int32_t ret = taosThreadMutexUnlock(&pMgmt->createLock);
+  if (ret != 0) {
+    dError("vgId:%d, failed to unlock since %s", req.vgId, tstrerror(ret));
+  }
 
 _OVER:
   if (code != 0) {