fix:fix error in table scan by group
This commit is contained in:
parent
f1860b7918
commit
a3033b59e6
|
@ -381,8 +381,7 @@ static SSDataBlock* doTableScanImpl(SOperatorInfo* pOperator) {
|
||||||
uint64_t *groupId = taosHashGet(pTableScanInfo->pGroupSet, pTableScanInfo->keyBuf, len);
|
uint64_t *groupId = taosHashGet(pTableScanInfo->pGroupSet, pTableScanInfo->keyBuf, len);
|
||||||
if (groupId) {
|
if (groupId) {
|
||||||
pBlock->info.groupId = *groupId;
|
pBlock->info.groupId = *groupId;
|
||||||
|
}else if(len != 0){
|
||||||
}else{
|
|
||||||
pBlock->info.groupId = calcGroupId(pTableScanInfo->keyBuf, len);
|
pBlock->info.groupId = calcGroupId(pTableScanInfo->keyBuf, len);
|
||||||
taosHashPut(pTableScanInfo->pGroupSet, pTableScanInfo->keyBuf, len, &pBlock->info.groupId, sizeof(uint64_t));
|
taosHashPut(pTableScanInfo->pGroupSet, pTableScanInfo->keyBuf, len, &pBlock->info.groupId, sizeof(uint64_t));
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue