From 17b5df0018bde1bb740dd36202f39f459f68b79a Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Sat, 31 Dec 2022 16:27:50 +0800 Subject: [PATCH] fix invalid vgroup id --- source/libs/catalog/src/ctgAsync.c | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/source/libs/catalog/src/ctgAsync.c b/source/libs/catalog/src/ctgAsync.c index 5d38b75c08..2242bdb994 100644 --- a/source/libs/catalog/src/ctgAsync.c +++ b/source/libs/catalog/src/ctgAsync.c @@ -906,7 +906,7 @@ int32_t ctgCallUserCb(void* param) { } void ctgUpdateJobErrCode(SCtgJob* pJob, int32_t errCode) { - if (!NEED_CLIENT_HANDLE_ERROR(errCode) || errCode == TSDB_CODE_SUCCESS) return; + 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) { @@ -916,11 +916,11 @@ void ctgUpdateJobErrCode(SCtgJob* pJob, int32_t errCode) { origCode = atomic_load_32(&pJob->jobResCode); } - if (NEED_CLIENT_HANDLE_ERROR(origCode)) { + if (NEED_CLIENT_REFRESH_VG_ERROR(origCode)) { return; } - if (NEED_CLIENT_HANDLE_ERROR(errCode)) { + if (NEED_CLIENT_REFRESH_VG_ERROR(errCode)) { atomic_store_32(&pJob->jobResCode, errCode); goto _return; } -- GitLab