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

fix: group cache last block index issue

This commit is contained in:
dapan1121 2023-07-20 10:55:15 +08:00
parent 58c5d5e70e
commit 3f58bc5578
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -580,7 +580,7 @@ static int32_t getBlkFromSessionCacheImpl(struct SOperatorInfo* pOperator, int64
int64_t* pIdx = taosArrayGet(pBatchList->pBlkList, 0); int64_t* pIdx = taosArrayGet(pBatchList->pBlkList, 0);
taosRUnLockLatch(&pBatchList->lock); taosRUnLockLatch(&pBatchList->lock);
code = retrieveBlkFromBufCache(pGCache, pSession->pGroupData, sessionId, *pIdx, &pSession->nextOffset, ppRes); code = retrieveBlkFromBufCache(pGCache, pSession->pGroupData, sessionId, *pIdx, &pSession->nextOffset, ppRes);
pSession->lastBlkId = *pIdx; pSession->lastBlkId = 0;
return code; return code;
} }
} else if (pSession->lastBlkId < blkNum) { } else if (pSession->lastBlkId < blkNum) {

3
source/libs/executor/src/scanoperator.c
View File

@ -797,7 +797,8 @@ static int32_t createTableListInfoFromParam(SOperatorInfo* pOperator) {
return TSDB_CODE_INVALID_PARA; return TSDB_CODE_INVALID_PARA;
} }
qError("add total %d dynamic tables to scan, tableSeq:%d, exist num:%" PRId64, num, pParam->tableSeq, (int64_t)taosArrayGetSize(pListInfo->pTableList)); qError("vgId:%d add total %d dynamic tables to scan, tableSeq:%d, exist num:%" PRId64,
pTaskInfo->id.vgId, num, pParam->tableSeq, (int64_t)taosArrayGetSize(pListInfo->pTableList));
if (pParam->tableSeq) { if (pParam->tableSeq) {
pListInfo->oneTableForEachGroup = true; pListInfo->oneTableForEachGroup = true;