diff --git a/src/logservice/libobcdc/src/ob_log_table_matcher.cpp b/src/logservice/libobcdc/src/ob_log_table_matcher.cpp
index 13accf90a..75dcbd85c 100644
--- a/src/logservice/libobcdc/src/ob_log_table_matcher.cpp
+++ b/src/logservice/libobcdc/src/ob_log_table_matcher.cpp
@@ -491,9 +491,9 @@ int ObLogTableMatcher::init(const char *tb_white_list,
 
   if (OB_ISNULL(tb_white_list) || OB_ISNULL(tb_black_list)
       || OB_ISNULL(tg_white_list) || OB_ISNULL(tg_black_list)) {
-    OBLOG_LOG(ERROR, "invalid_argument", K(tb_white_list), K(tb_black_list),
-        K(tg_white_list), K(tg_black_list));
     ret = OB_INVALID_ARGUMENT;
+    OBLOG_LOG(ERROR, "invalid_argument", KR(ret), K(tb_white_list), K(tb_black_list),
+        K(tg_white_list), K(tg_black_list));
   } else if (OB_FAIL(set_pattern_(tb_white_list))) {
     OBLOG_LOG(ERROR, "set table white list pattern fail", KR(ret), K(tb_white_list));
   } else if (OB_FAIL(set_black_pattern_(tb_black_list))) {
diff --git a/src/logservice/libobcdc/src/ob_log_timezone_info_getter.cpp b/src/logservice/libobcdc/src/ob_log_timezone_info_getter.cpp
index 4a406ca9c..b1e1647fd 100644
--- a/src/logservice/libobcdc/src/ob_log_timezone_info_getter.cpp
+++ b/src/logservice/libobcdc/src/ob_log_timezone_info_getter.cpp
@@ -325,8 +325,8 @@ int ObLogTimeZoneInfoGetter::fetch_tenant_timezone_info_(
     SMART_VAR(ObMySQLProxy::MySQLResult, res) {
       sqlclient::ObMySQLResult *result = nullptr;
       if (OB_ISNULL(mysql_proxy_)) {
-        LOG_ERROR("mysql_proxy_ is null", K(mysql_proxy_));
         ret = OB_ERR_UNEXPECTED;
+        LOG_ERROR("mysql_proxy_ is null", KR(ret), K(mysql_proxy_));
       } else if (! need_fetch_timezone_info_by_tennat_()) {
         if (OB_FAIL(mysql_proxy_->read(res, ObTimeZoneInfoManager::FETCH_TZ_INFO_SQL))) {
           LOG_WARN("fail to execute sql", KR(ret));
diff --git a/src/logservice/libobcdc/src/ob_log_trans_ctx.cpp b/src/logservice/libobcdc/src/ob_log_trans_ctx.cpp
index 945ea96c1..beac3d54e 100644
--- a/src/logservice/libobcdc/src/ob_log_trans_ctx.cpp
+++ b/src/logservice/libobcdc/src/ob_log_trans_ctx.cpp
@@ -541,9 +541,9 @@ int TransCtx::build_ready_participants_list_()
     // Linked list of participants
     for (int64_t index = 0; OB_SUCCESS == ret && index < participant_count_; index++) {
       if (OB_ISNULL(participants_[index].obj_)) {
-        LOG_ERROR("participant object is NULL", K(participants_[index]), K(index),
-            K(participant_count_), K(state_), K(trans_id_));
         ret = OB_ERR_UNEXPECTED;
+        LOG_ERROR("participant object is NULL", KR(ret), K(participants_[index]), K(index),
+            K(participant_count_), K(state_), K(trans_id_));
       } else if (index < participant_count_ - 1) {
         participants_[index].obj_->set_next_task(participants_[index + 1].obj_);
       } else {
@@ -663,9 +663,9 @@ int TransCtx::commit()
   ObSpinLockGuard guard(lock_);
 
   if (OB_ISNULL(ready_participant_objs_)) {
-    LOG_ERROR("ready participant objs is null",
-        KPC(ready_participant_objs_), KPC(this));
     ret = OB_ERR_UNEXPECTED;
+    LOG_ERROR("ready participant objs is null", KR(ret),
+        KPC(ready_participant_objs_), KPC(this));
   } else {
     const bool is_ddl_trans = ready_participant_objs_->is_ddl_trans();
 
@@ -754,9 +754,9 @@ int TransCtx::get_tenant_id(uint64_t &tenant_id) const
   int ret = OB_SUCCESS;
   ObSpinLockGuard guard(lock_);
   if (OB_ISNULL(ready_participant_objs_)) {
-    LOG_ERROR("ready participant objs is null, can not decide tenant id",
-        KPC(ready_participant_objs_), KPC(this));
     ret = OB_ERR_UNEXPECTED;
+    LOG_ERROR("ready participant objs is null, can not decide tenant id", KR(ret),
+        KPC(ready_participant_objs_), KPC(this));
   } else {
     // The tenant ID of the first participant is used as the tenant ID of the distributed transaction
     // TODO: support for cross-tenant transactions
diff --git a/src/observer/mysql/obmp_utils.cpp b/src/observer/mysql/obmp_utils.cpp
index 4b673f32a..c619ee9b1 100644
--- a/src/observer/mysql/obmp_utils.cpp
+++ b/src/observer/mysql/obmp_utils.cpp
@@ -115,8 +115,7 @@ int ObMPUtils::add_changed_session_info(OMPKOK &ok_pkt, sql::ObSQLSessionInfo &s
       if (name.empty()) {
         ret = OB_INVALID_ARGUMENT;
         LOG_WARN("invalid variable name", K(name), K(ret));
-      }
-      if (OB_FAIL(user_map.get_refactored(name, sess_var))) {
+      } else if (OB_FAIL(user_map.get_refactored(name, sess_var))) {
         LOG_WARN("unknown user variable", K(name), K(ret));
       } else {
         ObStringKV str_kv;
diff --git a/src/observer/ob_inner_sql_connection.cpp b/src/observer/ob_inner_sql_connection.cpp
index c5e84824b..e4128f4ea 100644
--- a/src/observer/ob_inner_sql_connection.cpp
+++ b/src/observer/ob_inner_sql_connection.cpp
@@ -272,7 +272,8 @@ void ObInnerSQLConnection::unref()
     ret = OB_NOT_INIT;
     LOG_WARN("not init", K(ret), K(lbt()));
   } else if (OB_ISNULL(pool_)) {
-    LOG_ERROR("not init conn pool");
+    ret = OB_ERR_UNEXPECTED;
+    LOG_ERROR("not init conn pool", K(ret));
   } else {
     if (0 == --ref_cnt_) {
       if (OB_FAIL(pool_->revert(this))) {
diff --git a/src/observer/ob_rpc_processor_simple.cpp b/src/observer/ob_rpc_processor_simple.cpp
index cc7e6ba59..c4eaa8e32 100644
--- a/src/observer/ob_rpc_processor_simple.cpp
+++ b/src/observer/ob_rpc_processor_simple.cpp
@@ -116,7 +116,8 @@ int ObRpcCheckBackupSchuedulerWorkingP::process()
 {
   int ret = OB_SUCCESS;
   if (OB_ISNULL(gctx_.root_service_)) {
-    LOG_ERROR("invalid argument", K(gctx_.root_service_));
+    ret = OB_ERR_UNEXPECTED;
+    LOG_ERROR("invalid argument", K(ret), K(gctx_.root_service_));
   } else {
     ret = gctx_.root_service_->check_backup_scheduler_working(result_);
   }
@@ -764,7 +765,8 @@ int ObRpcGetRoleP::process()
 {
   int ret = OB_SUCCESS;
   if (OB_ISNULL(gctx_.root_service_)) {
-    LOG_ERROR("invalid argument", K(gctx_.root_service_));
+    ret = OB_ERR_UNEXPECTED;
+    LOG_ERROR("invalid argument", K(ret), K(gctx_.root_service_));
   } else {
     ret = gctx_.ob_service_->get_root_server_status(result_);
   }
diff --git a/src/observer/omt/ob_multi_tenant.cpp b/src/observer/omt/ob_multi_tenant.cpp
index e36019c2e..41d8e2f5e 100644
--- a/src/observer/omt/ob_multi_tenant.cpp
+++ b/src/observer/omt/ob_multi_tenant.cpp
@@ -2073,7 +2073,8 @@ void ObMultiTenant::get_tenant_ids(TenantIdList &id_list)
        it != tenants_.end() && OB_SUCCESS == ret;
        it++) {
     if (OB_ISNULL(*it)) {
-      LOG_ERROR("unexpected condition", K(*it));
+      ret = OB_ERR_UNEXPECTED;
+      LOG_ERROR("unexpected condition", K(ret), K(*it));
     } else if (OB_FAIL(id_list.push_back((*it)->id()))) {
       LOG_ERROR("push tenant id to id list fail", K(ret));
     }
diff --git a/src/observer/omt/ob_tenant_srs.cpp b/src/observer/omt/ob_tenant_srs.cpp
index 53e7d69d2..12c7691f4 100644
--- a/src/observer/omt/ob_tenant_srs.cpp
+++ b/src/observer/omt/ob_tenant_srs.cpp
@@ -256,7 +256,8 @@ void ObTenantSrs::TenantSrsUpdateTask::runTimerTask()
 {
   int ret = OB_SUCCESS;
   if (OB_ISNULL(tenant_srs_)) {
-    LOG_WARN("failed to do srs update task. tenant_srs is null");
+    ret = OB_ERR_UNEXPECTED;
+    LOG_WARN("failed to do srs update task. tenant_srs is null", K(ret));
   } else if (OB_FAIL(tenant_srs_->refresh_sys_srs())) {
     if (ret != OB_ERR_EMPTY_QUERY) {
       LOG_WARN("failed to refresh sys srs", K(ret), K(tenant_srs_->remote_sys_srs_version_),
diff --git a/src/observer/omt/ob_tenant_timezone_mgr.cpp b/src/observer/omt/ob_tenant_timezone_mgr.cpp
index 0f1e3a518..5bbd7620e 100644
--- a/src/observer/omt/ob_tenant_timezone_mgr.cpp
+++ b/src/observer/omt/ob_tenant_timezone_mgr.cpp
@@ -344,7 +344,7 @@ int ObTenantTimezoneMgr::update_timezone_map()
     }
   }
   if (OB_FAIL(ret)) {
-  } else if (add_new_tenants(latest_tenant_ids)) {
+  } else if (OB_FAIL(add_new_tenants(latest_tenant_ids))) {
     LOG_WARN("add new tenants failed", K(ret));
   }
   return ret;
@@ -361,6 +361,7 @@ int ObTenantTimezoneMgr::get_tenant_tz(const uint64_t tenant_id,
 {
   int ret = OB_SUCCESS;
   if (OB_ISNULL(tenant_tz_map_getter_)) {
+    ret = OB_ERR_UNEXPECTED;
     LOG_ERROR("tenant tz map getter is null", K(ret), K(tenant_id));
   } else if (OB_FAIL(tenant_tz_map_getter_(tenant_id, timezone_wrap))) {
     LOG_WARN("get tenant tz map failed", K(ret), K(tenant_id));
diff --git a/src/observer/virtual_table/ob_all_virtual_proxy_schema.cpp b/src/observer/virtual_table/ob_all_virtual_proxy_schema.cpp
index cd05c8144..c152d8f9e 100644
--- a/src/observer/virtual_table/ob_all_virtual_proxy_schema.cpp
+++ b/src/observer/virtual_table/ob_all_virtual_proxy_schema.cpp
@@ -677,6 +677,7 @@ int ObAllVirtualProxySchema::get_view_decoded_schema_(
         resolver_ctx.expr_factory_ = &expr_factory;
         resolver_ctx.stmt_factory_ = &stmt_factory;
         if (OB_ISNULL(resolver_ctx.query_ctx_ = stmt_factory.get_query_ctx())) {
+          ret = OB_ERR_UNEXPECTED;
           LOG_WARN("create query context failed", KR(ret));
         } else {
           // set # of question marks
diff --git a/src/observer/virtual_table/ob_all_virtual_sql_workarea_active.cpp b/src/observer/virtual_table/ob_all_virtual_sql_workarea_active.cpp
index 2a92d47fc..504b0f0be 100644
--- a/src/observer/virtual_table/ob_all_virtual_sql_workarea_active.cpp
+++ b/src/observer/virtual_table/ob_all_virtual_sql_workarea_active.cpp
@@ -262,7 +262,9 @@ int ObSqlWorkareaActive::inner_get_next_row(common::ObNewRow *&row)
   }
   ObSqlWorkareaProfileInfo *wa_active = nullptr;
   uint64_t tenant_id = 0;
-  if (OB_FAIL(iter_.get_next_wa_active(wa_active, tenant_id))) {
+  if (OB_FAIL(ret)) {
+    // do nothing
+  } else if (OB_FAIL(iter_.get_next_wa_active(wa_active, tenant_id))) {
     if (OB_ITER_END != ret) {
       LOG_WARN("failed to get next channel", K(ret));
     }
diff --git a/src/observer/virtual_table/ob_all_virtual_sql_workarea_histogram.cpp b/src/observer/virtual_table/ob_all_virtual_sql_workarea_histogram.cpp
index 5367293e3..5aea0747d 100644
--- a/src/observer/virtual_table/ob_all_virtual_sql_workarea_histogram.cpp
+++ b/src/observer/virtual_table/ob_all_virtual_sql_workarea_histogram.cpp
@@ -213,7 +213,9 @@ int ObSqlWorkareaHistogram::inner_get_next_row(common::ObNewRow *&row)
   }
   ObWorkareaHistogram *wa_histogram = nullptr;
   uint64_t tenant_id = 0;
-  if (OB_FAIL(iter_.get_next_wa_histogram(wa_histogram, tenant_id))) {
+  if (OB_FAIL(ret)) {
+    // do nothing
+  } else if (OB_FAIL(iter_.get_next_wa_histogram(wa_histogram, tenant_id))) {
     if (OB_ITER_END != ret) {
       LOG_WARN("failed to get next channel", K(ret));
     }
diff --git a/src/observer/virtual_table/ob_all_virtual_sql_workarea_history_stat.cpp b/src/observer/virtual_table/ob_all_virtual_sql_workarea_history_stat.cpp
index 0faeb91e5..1edf6ae9f 100644
--- a/src/observer/virtual_table/ob_all_virtual_sql_workarea_history_stat.cpp
+++ b/src/observer/virtual_table/ob_all_virtual_sql_workarea_history_stat.cpp
@@ -282,7 +282,9 @@ int ObSqlWorkareaHistoryStat::inner_get_next_row(common::ObNewRow *&row)
   }
   ObSqlWorkAreaStat *wa_stat = nullptr;
   uint64_t tenant_id = 0;
-  if (OB_FAIL(iter_.get_next_wa_stat(wa_stat, tenant_id))) {
+  if (OB_FAIL(ret)) {
+    // do nothing
+  } else if (OB_FAIL(iter_.get_next_wa_stat(wa_stat, tenant_id))) {
     if (OB_ITER_END != ret) {
       LOG_WARN("failed to get next channel", K(ret));
     }
diff --git a/src/observer/virtual_table/ob_all_virtual_sql_workarea_memory_info.cpp b/src/observer/virtual_table/ob_all_virtual_sql_workarea_memory_info.cpp
index 2e8832ce3..ba79fd42e 100644
--- a/src/observer/virtual_table/ob_all_virtual_sql_workarea_memory_info.cpp
+++ b/src/observer/virtual_table/ob_all_virtual_sql_workarea_memory_info.cpp
@@ -218,7 +218,9 @@ int ObSqlWorkareaMemoryInfo::inner_get_next_row(common::ObNewRow *&row)
   }
   ObSqlWorkareaCurrentMemoryInfo *memory_info = nullptr;
   uint64_t tenant_id = 0;
-  if (OB_FAIL(iter_.get_next_wa_memory_info(memory_info, tenant_id))) {
+  if (OB_FAIL(ret)) {
+    // do nothing
+  } else if (OB_FAIL(iter_.get_next_wa_memory_info(memory_info, tenant_id))) {
     if (OB_ITER_END != ret) {
       LOG_WARN("failed to get next channel", K(ret));
     }
diff --git a/tools/ob_admin/dumpsst/ob_admin_dumpsst_executor.cpp b/tools/ob_admin/dumpsst/ob_admin_dumpsst_executor.cpp
index eda2ed371..50b66103f 100644
--- a/tools/ob_admin/dumpsst/ob_admin_dumpsst_executor.cpp
+++ b/tools/ob_admin/dumpsst/ob_admin_dumpsst_executor.cpp
@@ -355,8 +355,8 @@ int ObAdminDumpsstExecutor::init_master_key_getter()
   //   if (OB_FAIL(common::hex_to_cstr(key_hex_str_, len,
   //     master_key, share::OB_MAX_MASTER_KEY_LENGTH + 1))) {
   //     STORAGE_LOG(WARN, "fail to hex to cstr", K(ret));
-  //   } else if (share::ObMasterKeyGetter::instance().set_master_key(
-  //       master_key_id_, master_key, STRLEN(master_key))) {
+  //   } else if (OB_FAIL(share::ObMasterKeyGetter::instance().set_master_key(
+  //       master_key_id_, master_key, STRLEN(master_key)))) {
   //     STORAGE_LOG(WARN, "fail to set master key", K(ret));
   //   }
   // }