diff --git a/source/dnode/mgmt/mgmt_vnode/src/vmWorker.c b/source/dnode/mgmt/mgmt_vnode/src/vmWorker.c
index d15f97b0422d0234416d13b867369afbb5420d2b..a53127afceba4237043b53e06e315a9c169fba14 100644
--- a/source/dnode/mgmt/mgmt_vnode/src/vmWorker.c
+++ b/source/dnode/mgmt/mgmt_vnode/src/vmWorker.c
@@ -184,19 +184,22 @@ static void vmProcessApplyQueue(SQueueInfo *pInfo, STaosQall *qall, int32_t numO
 
   for (int32_t i = 0; i < numOfMsgs; ++i) {
 #if 1
+    // sync integration
+
     taosGetQitem(qall, (void **)&pMsg);
 
+    rsp.code = 0;
+    rsp.pCont = NULL;
+    rsp.contLen = 0;
+    if (vnodeProcessWriteReq(pVnode->pImpl, &pMsg->rpcMsg, version++, &rsp) < 0) {
+      rsp.code = terrno;
+      dTrace("vnodeProcessWriteReq error, code:%d", terrno);
+    }
+
     if (pMsg->rpcMsg.handle != NULL && pMsg->rpcMsg.ahandle != NULL) {
       rsp.ahandle = pMsg->rpcMsg.ahandle;
       rsp.handle = pMsg->rpcMsg.handle;
-      rsp.code = 0;
-      rsp.pCont = NULL;
-      rsp.contLen = 0;
-
-      if (vnodeProcessWriteReq(pVnode->pImpl, &pMsg->rpcMsg, version++, &rsp) < 0) {
-        rsp.code = terrno;
-        tmsgSendRsp(&rsp);
-      }
+      tmsgSendRsp(&rsp);
     }
 #endif
   }