[TD-2460]

This commit is contained in:
Haojun Liao 2020-12-16 15:11:55 +08:00
parent a9583d82cd
commit d4f9459a20
1 changed files with 6 additions and 9 deletions

View File

@ -2501,9 +2501,7 @@ void tscBuildResFromSubqueries(SSqlObj *pSql) {
tscRestoreSQLFuncForSTableQuery(pQueryInfo); tscRestoreSQLFuncForSTableQuery(pQueryInfo);
} }
while (1) {
assert (pRes->row >= pRes->numOfRows); assert (pRes->row >= pRes->numOfRows);
doBuildResFromSubqueries(pSql); doBuildResFromSubqueries(pSql);
if (pRes->code == TSDB_CODE_SUCCESS) { if (pRes->code == TSDB_CODE_SUCCESS) {
(*pSql->fp)(pSql->param, pSql, pRes->numOfRows); (*pSql->fp)(pSql->param, pSql, pRes->numOfRows);
@ -2511,7 +2509,6 @@ void tscBuildResFromSubqueries(SSqlObj *pSql) {
tscQueueAsyncRes(pSql); tscQueueAsyncRes(pSql);
} }
} }
}
static UNUSED_FUNC void transferNcharData(SSqlObj *pSql, int32_t columnIndex, TAOS_FIELD *pField) { static UNUSED_FUNC void transferNcharData(SSqlObj *pSql, int32_t columnIndex, TAOS_FIELD *pField) {
SSqlRes *pRes = &pSql->res; SSqlRes *pRes = &pSql->res;