From 0b8d3b056d5f130ddaf00be4b3394ef9469fd5ae Mon Sep 17 00:00:00 2001 From: Liu Jicong Date: Fri, 20 May 2022 18:58:17 +0800 Subject: [PATCH] fix: bad merge --- source/dnode/vnode/src/vnd/vnodeSvr.c | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/source/dnode/vnode/src/vnd/vnodeSvr.c b/source/dnode/vnode/src/vnd/vnodeSvr.c index c09b80af75..297b518ac7 100644 --- a/source/dnode/vnode/src/vnd/vnodeSvr.c +++ b/source/dnode/vnode/src/vnd/vnodeSvr.c @@ -184,8 +184,11 @@ int vnodeProcessFetchMsg(SVnode *pVnode, SRpcMsg *pMsg, SQueueInfo *pInfo) { case TDMT_VND_CONSUME: return tqProcessPollReq(pVnode->pTq, pMsg, pInfo->workerId); - case TDMT_VND_TASK_RUN: - return tqProcessTaskRunReq(pVnode->pTq, pMsg); + case TDMT_VND_TASK_RUN: { + int32_t code = tqProcessTaskRunReq(pVnode->pTq, pMsg); + pMsg->pCont = NULL; + return code; + } case TDMT_VND_TASK_DISPATCH: return tqProcessTaskDispatchReq(pVnode->pTq, pMsg); case TDMT_VND_TASK_RECOVER: