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

continue coding and save work

This commit is contained in:
shenglian zhou 2023-08-10 17:40:54 +08:00
parent b2e615d4e7
commit 20f5e2af5b
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -2913,7 +2913,6 @@ static SSDataBlock* doTagScanFromCtbIdx(SOperatorInfo* pOperator) {
SStorageAPI* pAPI = &pTaskInfo->storageAPI; SStorageAPI* pAPI = &pTaskInfo->storageAPI;
STagScanInfo* pInfo = pOperator->info; STagScanInfo* pInfo = pOperator->info;
SExprInfo* pExprInfo = &pOperator->exprSupp.pExprInfo[0];
SSDataBlock* pRes = pInfo->pRes; SSDataBlock* pRes = pInfo->pRes;
blockDataCleanup(pRes); blockDataCleanup(pRes);
int32_t count = 0; int32_t count = 0;
@ -2941,6 +2940,8 @@ static SSDataBlock* doTagScanFromCtbIdx(SOperatorInfo* pOperator) {
tagScanFilterByTagCond(aUidTags, pInfo->pTagCond, pInfo->readHandle.vnode, aUidTagIdxs, pAPI); tagScanFilterByTagCond(aUidTags, pInfo->pTagCond, pInfo->readHandle.vnode, aUidTagIdxs, pAPI);
} }
tagScanFillResultBlock(pOperator, pRes, aUidTags, aUidTagIdxs, pAPI); tagScanFillResultBlock(pOperator, pRes, aUidTags, aUidTagIdxs, pAPI);
count = taosArrayGetSize(aUidTagIdxs);
if (taosArrayGetSize(aUidTagIdxs) != 0) { if (taosArrayGetSize(aUidTagIdxs) != 0) {
break; break;
} }