From 39cd95d825bf23440140eefa2b4217066aa63294 Mon Sep 17 00:00:00 2001 From: Cary Xu Date: Wed, 24 Aug 2022 18:15:37 +0800 Subject: [PATCH] fix: while condition --- source/dnode/vnode/src/sma/smaRollup.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/dnode/vnode/src/sma/smaRollup.c b/source/dnode/vnode/src/sma/smaRollup.c index 02772b4cd0..426ab521fd 100644 --- a/source/dnode/vnode/src/sma/smaRollup.c +++ b/source/dnode/vnode/src/sma/smaRollup.c @@ -1707,7 +1707,7 @@ int32_t tdRSmaProcessExecImpl(SSma *pSma, ERsmaExecType type) { if (batchMax > 1) { batchMax = 100 / batchMax; } - while (occupied || (++batchCnt > batchMax)) { // greedy mode + while (occupied || (++batchCnt < batchMax)) { // greedy mode taosReadAllQitems(pInfo->queue, pInfo->qall); // queue has mutex lock int32_t qallItemSize = taosQallItemSize(pInfo->qall); if (qallItemSize > 0) { -- GitLab