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

fix: group cache save issue

This commit is contained in:
dapan1121 2023-04-17 16:09:54 +08:00
parent 20c9cea5f0
commit bd71cb8870
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
source/libs/executor/src/executil.c
View File

@ -492,6 +492,8 @@ int32_t getColInfoResultForGroupby(void* metaHandle, SNodeList* group, STableLis
if (lastTableList && (0 == memcmp(context.digest, lastMd5.digest, sizeof(lastMd5.digest)) && (taosArrayGetSize(pTableListInfo->pTableList) == taosArrayGetSize(lastTableList)))) {
pTableListInfo->pTableList = taosArrayDup(lastTableList, NULL);
goto end;
} else {
qError("group not hit, last:%p, lastSize:%d, newSize:%d", lastTableList, (int32_t)taosArrayGetSize(lastTableList), (int32_t)taosArrayGetSize(pTableListInfo->pTableList));
}
pUidTagList = taosArrayInit(8, sizeof(STUidTagInfo));
@ -620,11 +622,9 @@ int32_t getColInfoResultForGroupby(void* metaHandle, SNodeList* group, STableLis
info->groupId = calcGroupId(keyBuf, len);
}
if (memcmp(context.digest, lastMd5.digest, sizeof(lastMd5.digest))) {
memcpy(&lastMd5.digest, &context.digest, sizeof(context.digest));
taosArrayDestroy(lastTableList);
lastTableList = taosArrayDup(pTableListInfo->pTableList, NULL);
}
memcpy(&lastMd5.digest, &context.digest, sizeof(context.digest));
taosArrayDestroy(lastTableList);
lastTableList = taosArrayDup(pTableListInfo->pTableList, NULL);
// int64_t st2 = taosGetTimestampUs();
// qDebug("calculate tag block rows:%d, cost:%ld us", rows, st2-st1);