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

adjust

This commit is contained in:
Bob Liu 2023-12-28 21:54:16 +08:00
parent ef22830ca3
commit 9f8f69a791
1 changed files with 3 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -670,16 +670,12 @@ static int32_t initTableCountEnv(STableScanInfo* pTableScanInfo, const STableKey
return TSDB_CODE_OUT_OF_MEMORY; return TSDB_CODE_OUT_OF_MEMORY;
} }
} }
uint64_t groupId = 0; uint64_t groupId = pList->groupId;
for (int32_t i = 0; i < num; i++) { for (int32_t i = 0; i < num; i++) {
const STableKeyInfo* pInfo = pList + i; const STableKeyInfo* pInfo = pList + i;
if (pTableScanInfo->isSameGroup) { if (pTableScanInfo->isSameGroup && groupId != pInfo->groupId) {
if (i == 0) {
groupId = pInfo->groupId;
} else if (groupId != pInfo->groupId) {
pTableScanInfo->isSameGroup = false; pTableScanInfo->isSameGroup = false;
} }
}
taosHashPut(pTableScanInfo->pRemainTables, &(pInfo->uid), sizeof(pInfo->uid), &(pInfo->groupId), sizeof(pInfo->groupId)); taosHashPut(pTableScanInfo->pRemainTables, &(pInfo->uid), sizeof(pInfo->uid), &(pInfo->groupId), sizeof(pInfo->groupId));
} }
pTableScanInfo->countState = TABLE_COUNT_STATE_SCAN; pTableScanInfo->countState = TABLE_COUNT_STATE_SCAN;