xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix: group cache table index issue

This commit is contained in:
dapan1121 2023-07-20 11:00:29 +08:00
parent 3f58bc5578
commit 7221f447df
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
source/libs/executor/src/groupcacheoperator.c
View File

@ -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);