[td-3662]
This commit is contained in:
parent
859054fd48
commit
00c1a59abb
|
@ -351,7 +351,6 @@ void tscCreateLocalMerger(tExtMemBuffer **pMemBuffer, int32_t numOfBuffer, tOrde
|
||||||
}
|
}
|
||||||
|
|
||||||
assert(finalmodel->rowSize > 0 && finalmodel->rowSize <= pReducer->rowSize);
|
assert(finalmodel->rowSize > 0 && finalmodel->rowSize <= pReducer->rowSize);
|
||||||
printf("------xxxx:%d\n", pReducer->rowSize * pReducer->resColModel->capacity);
|
|
||||||
|
|
||||||
pReducer->pFinalRes = calloc(1, pReducer->rowSize * pReducer->resColModel->capacity);
|
pReducer->pFinalRes = calloc(1, pReducer->rowSize * pReducer->resColModel->capacity);
|
||||||
|
|
||||||
|
@ -944,7 +943,6 @@ static void genFinalResWithoutFill(SSqlRes* pRes, SLocalMerger *pLocalMerge, SQu
|
||||||
savePrevRecordAndSetupFillInfo(pLocalMerge, pQueryInfo, pLocalMerge->pFillInfo);
|
savePrevRecordAndSetupFillInfo(pLocalMerge, pQueryInfo, pLocalMerge->pFillInfo);
|
||||||
}
|
}
|
||||||
|
|
||||||
printf("size: %d\n", pRes->numOfRows * pLocalMerge->finalModel->rowSize);
|
|
||||||
memcpy(pRes->data, pBeforeFillData->data, (size_t)(pRes->numOfRows * pLocalMerge->finalModel->rowSize));
|
memcpy(pRes->data, pBeforeFillData->data, (size_t)(pRes->numOfRows * pLocalMerge->finalModel->rowSize));
|
||||||
|
|
||||||
pRes->numOfClauseTotal += pRes->numOfRows;
|
pRes->numOfClauseTotal += pRes->numOfRows;
|
||||||
|
|
|
@ -160,7 +160,7 @@ if $data03 != @abc15@ then
|
||||||
endi
|
endi
|
||||||
|
|
||||||
#sql select top(c6, 3) from select_tags_mt0 interval(10a)
|
#sql select top(c6, 3) from select_tags_mt0 interval(10a)
|
||||||
|
#sql select top(c6, 3) from select_tags_mt0 interval(10a) group by tbname;
|
||||||
|
|
||||||
sql select top(c1, 100), tbname, t1, t2 from select_tags_mt0;
|
sql select top(c1, 100), tbname, t1, t2 from select_tags_mt0;
|
||||||
if $rows != 100 then
|
if $rows != 100 then
|
||||||
|
|
Loading…
Reference in New Issue