fix: fetch row failed issue

This commit is contained in:
dapan1121 2024-07-31 15:37:21 +08:00
parent 0205291bcf
commit 8e23cbfa2e
1 changed files with 4 additions and 2 deletions

View File

@ -2920,8 +2920,10 @@ void taosAsyncFetchImpl(SRequestObj* pRequest, __taos_async_fn_t fp, void* param
.cbParam = pRequest, .cbParam = pRequest,
}; };
if (TSDB_CODE_SUCCESS != schedulerFetchRows(pRequest->body.queryJob, &req)) { int32_t code = schedulerFetchRows(pRequest->body.queryJob, &req);
tscError("0x%" PRIx64 " failed to schedule fetch rows", pRequest->self); if (TSDB_CODE_SUCCESS != code) {
tscError("0x%" PRIx64 " failed to schedule fetch rows", pRequest->requestId);
pRequest->body.fetchFp(param, pRequest, code);
} }
} }