Merge pull request #7544 from taosdata/hotfix/TD-6282
[td-6282]fix nested query no return issue
This commit is contained in:
commit
48043bd4f8
|
@ -3778,6 +3778,8 @@ static void tscSubqueryCompleteCallback(void* param, TAOS_RES* tres, int code) {
|
||||||
tscDebug("0x%"PRIx64" all subquery response received, retry", pParentSql->self);
|
tscDebug("0x%"PRIx64" all subquery response received, retry", pParentSql->self);
|
||||||
|
|
||||||
if (code && !((code == TSDB_CODE_TDB_INVALID_TABLE_ID || code == TSDB_CODE_VND_INVALID_VGROUP_ID) && pParentSql->retry < pParentSql->maxRetry)) {
|
if (code && !((code == TSDB_CODE_TDB_INVALID_TABLE_ID || code == TSDB_CODE_VND_INVALID_VGROUP_ID) && pParentSql->retry < pParentSql->maxRetry)) {
|
||||||
|
pParentSql->res.code = code;
|
||||||
|
|
||||||
tscAsyncResultOnError(pParentSql);
|
tscAsyncResultOnError(pParentSql);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
@ -3858,6 +3860,7 @@ void executeQuery(SSqlObj* pSql, SQueryInfo* pQueryInfo) {
|
||||||
pNew->signature = pNew;
|
pNew->signature = pNew;
|
||||||
pNew->sqlstr = strdup(pSql->sqlstr);
|
pNew->sqlstr = strdup(pSql->sqlstr);
|
||||||
pNew->fp = tscSubqueryCompleteCallback;
|
pNew->fp = tscSubqueryCompleteCallback;
|
||||||
|
pNew->fetchFp = tscSubqueryCompleteCallback;
|
||||||
pNew->maxRetry = pSql->maxRetry;
|
pNew->maxRetry = pSql->maxRetry;
|
||||||
|
|
||||||
pNew->cmd.resColumnId = TSDB_RES_COL_ID;
|
pNew->cmd.resColumnId = TSDB_RES_COL_ID;
|
||||||
|
|
Loading…
Reference in New Issue