From 8ea6b545b8037a0f9f77f51886811cebb1983c57 Mon Sep 17 00:00:00 2001 From: dapan1121 Date: Thu, 23 Feb 2023 15:04:31 +0800 Subject: [PATCH] fix: restore catalog job error --- source/libs/catalog/src/ctgAsync.c | 9 ++------- 1 file changed, 2 insertions(+), 7 deletions(-) diff --git a/source/libs/catalog/src/ctgAsync.c b/source/libs/catalog/src/ctgAsync.c index 1276f2796f..89e92b0cc8 100644 --- a/source/libs/catalog/src/ctgAsync.c +++ b/source/libs/catalog/src/ctgAsync.c @@ -906,14 +906,9 @@ int32_t ctgCallUserCb(void* param) { } 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); - } else if (0 != atomic_val_compare_exchange_32(&pJob->jobResCode, 0, errCode)) { - return; - } - + atomic_store_32(&pJob->jobResCode, errCode); qDebug("QID:0x%" PRIx64 " ctg job errCode updated to %s", pJob->queryId, tstrerror(errCode)); return; }