From 5b7b8a97b428777fdc7f83dc4761c212c17e5607 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Wed, 4 Jan 2023 10:48:38 +0800 Subject: [PATCH] fix invalid vgroup id --- source/libs/catalog/src/ctgAsync.c | 21 ++------------------- 1 file changed, 2 insertions(+), 19 deletions(-) diff --git a/source/libs/catalog/src/ctgAsync.c b/source/libs/catalog/src/ctgAsync.c index 2242bdb994..438128203e 100644 --- a/source/libs/catalog/src/ctgAsync.c +++ b/source/libs/catalog/src/ctgAsync.c @@ -908,26 +908,9 @@ int32_t ctgCallUserCb(void* param) { void ctgUpdateJobErrCode(SCtgJob* pJob, int32_t errCode) { if (!NEED_CLIENT_REFRESH_VG_ERROR(errCode) || errCode == TSDB_CODE_SUCCESS) return; - int32_t origCode = atomic_load_32(&pJob->jobResCode); - if (TSDB_CODE_SUCCESS == origCode) { - if (origCode == atomic_val_compare_exchange_32(&pJob->jobResCode, origCode, errCode)) { - goto _return; - } - origCode = atomic_load_32(&pJob->jobResCode); - } - - if (NEED_CLIENT_REFRESH_VG_ERROR(origCode)) { - return; - } - - if (NEED_CLIENT_REFRESH_VG_ERROR(errCode)) { - atomic_store_32(&pJob->jobResCode, errCode); - goto _return; - } - return; - -_return: + atomic_store_32(&pJob->jobResCode, errCode); qDebug("QID:0x%" PRIx64 " ctg job errCode updated to %s", pJob->queryId, tstrerror(errCode)); + return; } int32_t ctgHandleTaskEnd(SCtgTask* pTask, int32_t rspCode) { -- GitLab