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

fix: grou cache issue

This commit is contained in:
dapan1121 2023-04-17 15:33:54 +08:00
parent 4506813ddb
commit 31d187444e
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -454,7 +454,7 @@ int32_t getColInfoResultForGroupby(void* metaHandle, SNodeList* group, STableLis
SSDataBlock* pResBlock = NULL;
void* keyBuf = NULL;
SArray* groupData = NULL;
static T_MD5_CTX lastMd5 = {0};
static T_MD5_CTX lastMd5 = {-1};
static SArray* lastTableList = NULL;
int32_t rows = taosArrayGetSize(pTableListInfo->pTableList);
@ -483,14 +483,14 @@ int32_t getColInfoResultForGroupby(void* metaHandle, SNodeList* group, STableLis
}
T_MD5_CTX context = {0};
if (lastTableList) {
SNodeListNode* listNode = (SNodeListNode*)nodesMakeNode(QUERY_NODE_NODE_LIST);
listNode->pNodeList = group;
genTagFilterDigest((SNode *)listNode, &context);
if (0 == memcmp(context.digest, lastMd5.digest, sizeof(lastMd5.digest)) && (taosArrayGetSize(pTableListInfo->pTableList) == taosArrayGetSize(lastTableList))) {
pTableListInfo->pTableList = taosArrayDup(lastTableList, NULL);
goto end;
}
SNodeListNode* listNode = (SNodeListNode*)nodesMakeNode(QUERY_NODE_NODE_LIST);
listNode->pNodeList = group;
genTagFilterDigest((SNode *)listNode, &context);
taosMemoryFree(listNode);
if (lastTableList && (0 == memcmp(context.digest, lastMd5.digest, sizeof(lastMd5.digest)) && (taosArrayGetSize(pTableListInfo->pTableList) == taosArrayGetSize(lastTableList)))) {
pTableListInfo->pTableList = taosArrayDup(lastTableList, NULL);
goto end;
}
SArray* pUidTagList = taosArrayInit(8, sizeof(STUidTagInfo));