xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix: correct ctg job error code

This commit is contained in:
dapan1121 2023-02-03 16:38:09 +08:00
parent 96c76dc649
commit bc98324c1d
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
source/libs/catalog/src/ctgAsync.c
View File

@ -906,9 +906,14 @@ int32_t ctgCallUserCb(void* param) {
} }
void ctgUpdateJobErrCode(SCtgJob* pJob, int32_t errCode) { void ctgUpdateJobErrCode(SCtgJob* pJob, int32_t errCode) {
if (!NEED_CLIENT_REFRESH_VG_ERROR(errCode) || errCode == TSDB_CODE_SUCCESS) return; if (errCode == TSDB_CODE_SUCCESS) return;
atomic_store_32(&pJob->jobResCode, errCode); if (NEED_CLIENT_HANDLE_ERROR(errCode)) {
atomic_store_32(&pJob->jobResCode, errCode);
} else if (0 != atomic_val_compare_exchange_32(&pJob->jobResCode, 0, errCode)) {
return;
}
qDebug("QID:0x%" PRIx64 " ctg job errCode updated to %s", pJob->queryId, tstrerror(errCode)); qDebug("QID:0x%" PRIx64 " ctg job errCode updated to %s", pJob->queryId, tstrerror(errCode));
return; return;
} }