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

fix(query): fix error.

This commit is contained in:
Haojun Liao 2024-07-28 01:26:47 +08:00
parent 0ad364f707
commit bf3b2e8dde
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
source/libs/executor/src/mergejoin.c
View File

@ -2837,11 +2837,12 @@ static int32_t mWinJoinCloneCacheBlk(SMJoinWindowCtx* pCtx) {
if (!pGrp->clonedBlk) { if (!pGrp->clonedBlk) {
if (0 == pGrp->beginIdx) { if (0 == pGrp->beginIdx) {
pGrp->blk = NULL; SSDataBlock* p = NULL;
int32_t code = createOneDataBlock(pGrp->blk, true, &pGrp->blk); int32_t code = createOneDataBlock(pGrp->blk, true, &p);
if (code) { if (code) {
MJ_ERR_RET(code); MJ_ERR_RET(code);
} }
pGrp->blk = p;
} else { } else {
pGrp->blk = blockDataExtractBlock(pGrp->blk, pGrp->beginIdx, pGrp->blk->info.rows - pGrp->beginIdx); pGrp->blk = blockDataExtractBlock(pGrp->blk, pGrp->beginIdx, pGrp->blk->info.rows - pGrp->beginIdx);
pGrp->endIdx -= pGrp->beginIdx; pGrp->endIdx -= pGrp->beginIdx;