From 4169eb559a2e08a39a97db6376640384601475de Mon Sep 17 00:00:00 2001 From: Liu Jicong Date: Tue, 31 May 2022 17:02:43 +0800 Subject: [PATCH] fix(tmq): skip log --- source/dnode/vnode/src/tq/tq.c | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/source/dnode/vnode/src/tq/tq.c b/source/dnode/vnode/src/tq/tq.c index 16201994f0..b4747f2264 100644 --- a/source/dnode/vnode/src/tq/tq.c +++ b/source/dnode/vnode/src/tq/tq.c @@ -441,14 +441,8 @@ int32_t tqProcessPollReq(STQ* pTq, SRpcMsg* pMsg, int32_t workerId) { break; } - tqDebug("tmq poll vg %d: offset %ld msgType %d", pTq->pVnode->config.vgId, fetchOffset, - pHeadWithCkSum->head.msgType); - SWalReadHead* pHead = &pHeadWithCkSum->head; - tqDebug("tmq poll vg %d: offset %ld msgType %d", pTq->pVnode->config.vgId, fetchOffset, - pHeadWithCkSum->head.msgType); - #if 0 SWalReadHead* pHead; if (walReadWithHandle_s(pExec->pWalReader, fetchOffset, &pHead) < 0) { @@ -499,6 +493,8 @@ int32_t tqProcessPollReq(STQ* pTq, SRpcMsg* pMsg, int32_t workerId) { // TODO continue scan until meeting batch requirement if (rsp.blockNum > 0 /* threshold */) { break; + } else { + fetchOffset++; } }