diff --git a/include/common/tmsg.h b/include/common/tmsg.h
index 768f02d9ba7213aad6125f12fdd73bcca37768da..972181f77e8c5be57559a87178fb158aafe7d937 100644
--- a/include/common/tmsg.h
+++ b/include/common/tmsg.h
@@ -241,6 +241,7 @@ typedef struct {
   int32_t schemaLen;  // schema length, if length is 0, no schema exists
   int16_t numOfRows;  // total number of rows in current submit block
   // head of SSubmitBlk
+  int32_t     numOfBlocks;
   const void* pMsg;
 } SSubmitMsgIter;
 
diff --git a/source/common/src/tmsg.c b/source/common/src/tmsg.c
index 9c6c532bcd071bf8799e28076a9ea147d5b81443..e7ee164be725465a0368e39d2f7dcfc9a24eb5d9 100644
--- a/source/common/src/tmsg.c
+++ b/source/common/src/tmsg.c
@@ -35,6 +35,7 @@ int32_t tInitSubmitMsgIter(const SSubmitReq *pMsg, SSubmitMsgIter *pIter) {
   }
 
   pIter->totalLen = htonl(pMsg->length);
+  pIter->numOfBlocks = htonl(pMsg->numOfBlocks);
   ASSERT(pIter->totalLen > 0);
   pIter->len = 0;
   pIter->pMsg = pMsg;