fix query crash

8a180a33 · Liu Jicong · 0712f87d · 8a180a33
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

source/dnode/mnode/impl/src/mndSubscribe.c source/dnode/mnode/impl/src/mndSubscribe.c +1 -1

未找到文件。
--- a/source/dnode/mnode/impl/src/mndSubscribe.c
+++ b/source/dnode/mnode/impl/src/mndSubscribe.c
@@ -233,7 +233,7 @@ static int32_t mndProcessMqTimerMsg(SMnodeMsg *pMsg) {
        STransAction action = {0};
        action.epSet = pCEp->epSet;
        action.pCont = buf;
-        action.contLen = tlen;
+        action.contLen = sizeof(SMsgHead) + tlen;
        action.msgType = TDMT_VND_MQ_SET_CONN;
        mndTransAppendRedoAction(pTrans, &action);