diff --git a/source/dnode/mgmt/implement/src/dmExec.c b/source/dnode/mgmt/implement/src/dmExec.c
index 06001028b5..bb0206d229 100644
--- a/source/dnode/mgmt/implement/src/dmExec.c
+++ b/source/dnode/mgmt/implement/src/dmExec.c
@@ -192,15 +192,15 @@ void dmCloseNode(SMgmtWrapper *pWrapper) {
 
   dmStopNode(pWrapper);
 
-  taosWLockLatch(&pWrapper->latch);
-  (*pWrapper->fp.closeFp)(pWrapper);
-  taosWUnLockLatch(&pWrapper->latch);
-
   if (pWrapper->procObj) {
     taosProcCleanup(pWrapper->procObj);
     pWrapper->procObj = NULL;
   }
 
+  taosWLockLatch(&pWrapper->latch);
+  (*pWrapper->fp.closeFp)(pWrapper);
+  taosWUnLockLatch(&pWrapper->latch);
+
   dInfo("node:%s, has been closed", pWrapper->name);
 }