diff --git a/source/libs/catalog/src/ctgAsync.c b/source/libs/catalog/src/ctgAsync.c
index 325d6e0e46c61e398e3766b931fe6141abd710c4..f84f8e2917e6190e592826bf5eb52bc38af3dd28 100644
--- a/source/libs/catalog/src/ctgAsync.c
+++ b/source/libs/catalog/src/ctgAsync.c
@@ -906,9 +906,14 @@ int32_t ctgCallUserCb(void* param) {
 }
 
 void ctgUpdateJobErrCode(SCtgJob* pJob, int32_t errCode) {
-  if (!NEED_CLIENT_REFRESH_VG_ERROR(errCode) || errCode == TSDB_CODE_SUCCESS) return;
+  if (errCode == TSDB_CODE_SUCCESS) return;
 
-  atomic_store_32(&pJob->jobResCode, errCode);
+  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;
+  }
+  
   qDebug("QID:0x%" PRIx64 " ctg job errCode updated to %s", pJob->queryId, tstrerror(errCode));
   return;
 }