From ce61b2ab00a6cff7b7fcd2904a40828963b8b73f Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Thu, 18 May 2023 11:35:45 +0800 Subject: [PATCH] fix: fix syntax error in tqRead --- source/dnode/vnode/src/tq/tqRead.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/dnode/vnode/src/tq/tqRead.c b/source/dnode/vnode/src/tq/tqRead.c index 9e245fb45d..53c2da42c6 100644 --- a/source/dnode/vnode/src/tq/tqRead.c +++ b/source/dnode/vnode/src/tq/tqRead.c @@ -386,7 +386,7 @@ bool tqNextBlockInWal(STqReader* pReader, const char* id) { pReader->nextBlk = 0; } - size_t numOfBlocks = taosArrayGetSize(pReader->submit.aSubmitTbData); + int32_t numOfBlocks = taosArrayGetSize(pReader->submit.aSubmitTbData); while (pReader->nextBlk < numOfBlocks) { tqDebug("tq reader next data block %d/%d, len:%d %" PRId64 " %d", pReader->nextBlk, numOfBlocks, pReader->msg.msgLen, pReader->msg.ver, pReader->nextBlk);