fix(query): assign the result number.
This commit is contained in:
parent
33c075542d
commit
4ca49bf549
|
@ -1242,6 +1242,7 @@ int32_t scalarCalculate(SNode *pNode, SArray *pBlockList, SScalarParam *pDst) {
|
||||||
colInfoDataEnsureCapacity(pDst->columnData, res->numOfRows);
|
colInfoDataEnsureCapacity(pDst->columnData, res->numOfRows);
|
||||||
colDataAssign(pDst->columnData, res->columnData, res->numOfRows, NULL);
|
colDataAssign(pDst->columnData, res->columnData, res->numOfRows, NULL);
|
||||||
pDst->numOfRows = res->numOfRows;
|
pDst->numOfRows = res->numOfRows;
|
||||||
|
pDst->numOfQualified = res->numOfQualified;
|
||||||
}
|
}
|
||||||
|
|
||||||
sclFreeParam(res);
|
sclFreeParam(res);
|
||||||
|
|
Loading…
Reference in New Issue