diff --git a/src/dnode/src/dnodeMWrite.c b/src/dnode/src/dnodeMWrite.c
index 4bd1eae25ba37a18c03cb0fcb6989105b0799c5e..8c9e22ef4b19133863f32140fb6ddae292caf5a9 100644
--- a/src/dnode/src/dnodeMWrite.c
+++ b/src/dnode/src/dnodeMWrite.c
@@ -188,8 +188,8 @@ void dnodeReprocessMWriteMsg(void *pMsg) {
       ++pWrite->pBatchMasterMsg->received;
       if (pWrite->pBatchMasterMsg->successed + pWrite->pBatchMasterMsg->received
 	  >= pWrite->pBatchMasterMsg->expected) {
-	dnodeSendRedirectMsg(&pWrite->rpcMsg, true);
-	dnodeFreeMWriteMsg(pWrite);
+        dnodeSendRedirectMsg(&pWrite->pBatchMasterMsg->rpcMsg, true);
+        dnodeFreeMWriteMsg(pWrite->pBatchMasterMsg);
       }
 
       mnodeDestroySubMsg(pWrite);