提交 8ea6b545 编写于 作者: D dapan1121

fix: restore catalog job error

上级 25c555a5
...@@ -906,14 +906,9 @@ int32_t ctgCallUserCb(void* param) { ...@@ -906,14 +906,9 @@ int32_t ctgCallUserCb(void* param) {
} }
void ctgUpdateJobErrCode(SCtgJob* pJob, int32_t errCode) { void ctgUpdateJobErrCode(SCtgJob* pJob, int32_t errCode) {
if (errCode == TSDB_CODE_SUCCESS) return; if (!NEED_CLIENT_REFRESH_VG_ERROR(errCode) || errCode == TSDB_CODE_SUCCESS) return;
if (NEED_CLIENT_HANDLE_ERROR(errCode)) { atomic_store_32(&pJob->jobResCode, 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;
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册