diff --git a/source/dnode/mgmt/node_mgmt/src/dmTransport.c b/source/dnode/mgmt/node_mgmt/src/dmTransport.c index add192319b..3dc0572927 100644 --- a/source/dnode/mgmt/node_mgmt/src/dmTransport.c +++ b/source/dnode/mgmt/node_mgmt/src/dmTransport.c @@ -139,7 +139,11 @@ _OVER: } } SRpcMsg rspMsg = {.code = code, .info = pRpc->info}; - tmsgSendRsp(&rspMsg); + if (pWrapper != NULL) { + tmsgSendRsp(&rspMsg); + } else { + rpcSendResponse(&rspMsg); + } } dTrace("msg:%p, is freed", pMsg);