From 7221f447df5160aac51997527a3dd37bb1de25a6 Mon Sep 17 00:00:00 2001 From: dapan1121 Date: Thu, 20 Jul 2023 11:00:29 +0800 Subject: [PATCH] fix: group cache table index issue --- source/libs/executor/src/groupcacheoperator.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/libs/executor/src/groupcacheoperator.c b/source/libs/executor/src/groupcacheoperator.c index 7a55b42e1a..f56fc98285 100755 --- a/source/libs/executor/src/groupcacheoperator.c +++ b/source/libs/executor/src/groupcacheoperator.c @@ -583,7 +583,7 @@ static int32_t getBlkFromSessionCacheImpl(struct SOperatorInfo* pOperator, int64 pSession->lastBlkId = 0; return code; } - } else if (pSession->lastBlkId < blkNum) { + } else if ((pSession->lastBlkId + 1) < blkNum) { int64_t* pIdx = taosArrayGet(pBatchList->pBlkList, pSession->lastBlkId + 1); taosRUnLockLatch(&pBatchList->lock); code = retrieveBlkFromBufCache(pGCache, pSession->pGroupData, sessionId, *pIdx, &pSession->nextOffset, ppRes);