diff --git a/src/mnode/src/mnodeProfile.c b/src/mnode/src/mnodeProfile.c
index 95c83af8d20dc6cea8e00b43ae7d56603806fab1..7c35829f88f4e7d1753a3ee00b13a9f87d03ae48 100644
--- a/src/mnode/src/mnodeProfile.c
+++ b/src/mnode/src/mnodeProfile.c
@@ -282,6 +282,8 @@ static int32_t mnodeRetrieveConns(SShowObj *pShow, char *data, int32_t rows, voi
 
 // not thread safe, need optimized
 int32_t mnodeSaveQueryStreamList(SConnObj *pConn, SHeartBeatMsg *pHBMsg) {
+  pConn->numOfQueries = 0;	
+  pConn->numOfStreams = 0;
   int32_t numOfQueries = htonl(pHBMsg->numOfQueries);
   int32_t numOfStreams = htonl(pHBMsg->numOfStreams);