diff --git a/source/dnode/mnode/impl/test/stream/stream.cpp b/source/dnode/mnode/impl/test/stream/stream.cpp
index ae00f47ab7..8480f204d6 100644
--- a/source/dnode/mnode/impl/test/stream/stream.cpp
+++ b/source/dnode/mnode/impl/test/stream/stream.cpp
@@ -92,7 +92,11 @@ SRpcMsg buildHbReq() {
   }
   tEncoderClear(&encoder);
 
-  initRpcMsg(&msg1, TDMT_MND_STREAM_HEARTBEAT, buf, tlen);
+  {
+    msg1.msgType = TDMT_MND_STREAM_HEARTBEAT;
+    msg1.pCont = buf;
+    msg1.contLen = tlen;
+  }
 
   taosArrayDestroy(msg.pTaskStatus);
   return msg1;