diff --git a/source/dnode/vnode/inc/vnode.h b/source/dnode/vnode/inc/vnode.h
index fe48def982..130cf9999a 100644
--- a/source/dnode/vnode/inc/vnode.h
+++ b/source/dnode/vnode/inc/vnode.h
@@ -221,10 +221,10 @@ typedef struct SSnapContext {
 } SSnapContext;
 
 typedef struct STqReader {
-  const SSubmitReq *pMsg;
-  //  SSubmitBlk       *pBlock;
-  //  SSubmitMsgIter    msgIter;
-  //  SSubmitBlkIter    blkIter;
+  // const SSubmitReq *pMsg;
+  //   SSubmitBlk       *pBlock;
+  //   SSubmitMsgIter    msgIter;
+  //   SSubmitBlkIter    blkIter;
 
   int64_t       ver;
   SPackedSubmit msg2;
diff --git a/source/dnode/vnode/src/tq/tq.c b/source/dnode/vnode/src/tq/tq.c
index cade8b6a7a..330018d619 100644
--- a/source/dnode/vnode/src/tq/tq.c
+++ b/source/dnode/vnode/src/tq/tq.c
@@ -673,10 +673,8 @@ int32_t tqProcessPollReq(STQ* pTq, SRpcMsg* pMsg) {
               req.epoch, TD_VID(pTq->pVnode), fetchVer, pHead->msgType);
 
       if (pHead->msgType == TDMT_VND_SUBMIT) {
-        SSubmitReq* pCont = (SSubmitReq*)&pHead->body;
-
         SPackedSubmit submit = {
-            .msgStr = pCont,
+            .msgStr = pHead->body,
             .msgLen = pHead->bodyLen,
             .ver = pHead->version,
         };