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

[TD-5799]<fix> fix compile error

This commit is contained in:
yihaoDeng 2021-08-08 07:15:15 +08:00
parent c68ae361b2
commit 8e48713565
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/query/src/qExecutor.c
View File

@ -6616,7 +6616,7 @@ static bool initMultiDistinctInfo(SDistinctOperatorInfo *pInfo, SOperatorInfo* p
pInfo->totalBytes += pOperator->pExpr[i].base.colBytes; pInfo->totalBytes += pOperator->pExpr[i].base.colBytes;
} }
for (int i = 0; i < pOperator->numOfOutput; i++) { for (int i = 0; i < pOperator->numOfOutput; i++) {
int numOfBlock = taosArrayGetSize(pBlock->pDataBlock); int numOfBlock = (int)(taosArrayGetSize(pBlock->pDataBlock));
assert(i < numOfBlock); assert(i < numOfBlock);
for (int j = 0; j < numOfBlock; j++) { for (int j = 0; j < numOfBlock; j++) {
SColumnInfoData* pColDataInfo = taosArrayGet(pBlock->pDataBlock, j); SColumnInfoData* pColDataInfo = taosArrayGet(pBlock->pDataBlock, j);
@ -6626,7 +6626,7 @@ static bool initMultiDistinctInfo(SDistinctOperatorInfo *pInfo, SOperatorInfo* p
} }
} }
} }
pInfo->totalBytes += strlen(MULTI_KEY_DELIM) * (pOperator->numOfOutput); pInfo->totalBytes += (int32_t)strlen(MULTI_KEY_DELIM) * (pOperator->numOfOutput);
pInfo->buf = calloc(1, pInfo->totalBytes); pInfo->buf = calloc(1, pInfo->totalBytes);
return taosArrayGetSize(pInfo->pDistinctDataInfo) == pOperator->numOfOutput ? true : false; return taosArrayGetSize(pInfo->pDistinctDataInfo) == pOperator->numOfOutput ? true : false;
} }