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

fix invalid vgroup id

This commit is contained in:
yihaoDeng 2022-12-31 16:27:50 +08:00
parent 69fab69932
commit 17b5df0018
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -906,7 +906,7 @@ int32_t ctgCallUserCb(void* param) {
} }
void ctgUpdateJobErrCode(SCtgJob* pJob, int32_t errCode) { 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); int32_t origCode = atomic_load_32(&pJob->jobResCode);
if (TSDB_CODE_SUCCESS == origCode) { if (TSDB_CODE_SUCCESS == origCode) {
@ -916,11 +916,11 @@ void ctgUpdateJobErrCode(SCtgJob* pJob, int32_t errCode) {
origCode = atomic_load_32(&pJob->jobResCode); origCode = atomic_load_32(&pJob->jobResCode);
} }
if (NEED_CLIENT_HANDLE_ERROR(origCode)) { if (NEED_CLIENT_REFRESH_VG_ERROR(origCode)) {
return; return;
} }
if (NEED_CLIENT_HANDLE_ERROR(errCode)) { if (NEED_CLIENT_REFRESH_VG_ERROR(errCode)) {
atomic_store_32(&pJob->jobResCode, errCode); atomic_store_32(&pJob->jobResCode, errCode);
goto _return; goto _return;
} }