diff --git a/src/sql/session/ob_basic_session_info.cpp b/src/sql/session/ob_basic_session_info.cpp
index 8b9b3f12c1460ecc1b93a09f63fde6561e0cbb08..bd23dd70c77990ed37bc4d4b04bc9d716521317f 100644
--- a/src/sql/session/ob_basic_session_info.cpp
+++ b/src/sql/session/ob_basic_session_info.cpp
@@ -4345,6 +4345,8 @@ int ObBasicSessionInfo::trans_save_session(TransSavedValue& saved_value)
   OX(trans_result_.reset());
   OX(saved_value.nested_count_ = nested_count_);
   OX(nested_count_ = -1);
+  OX(saved_value.trans_consistency_type_ = trans_consistency_type_);
+  OX(trans_consistency_type_ = transaction::ObTransConsistencyType::UNKNOWN);
   return ret;
 }
 
@@ -4356,6 +4358,7 @@ int ObBasicSessionInfo::trans_restore_session(TransSavedValue& saved_value)
   OX(trans_flags_ = saved_value.trans_flags_);
   OZ(trans_desc_.trans_deep_copy(saved_value.trans_desc_));
   OZ(base_restore_session(saved_value));
+  OX(trans_consistency_type_ = saved_value.trans_consistency_type_);
   return ret;
 }
 
diff --git a/src/sql/session/ob_basic_session_info.h b/src/sql/session/ob_basic_session_info.h
index 02b5a39419a47d96f17bd9dea2094d3c66efdfa9..d9003558cf9c1324a0b8cc4a26af8c5e0703e507 100644
--- a/src/sql/session/ob_basic_session_info.h
+++ b/src/sql/session/ob_basic_session_info.h
@@ -378,6 +378,7 @@ public:
       trans_flags_.reset();
       trans_result_.reset();
       nested_count_ = -1;
+      trans_consistency_type_ = transaction::ObTransConsistencyType::UNKNOWN;
     }
 
   public:
@@ -385,6 +386,7 @@ public:
     TransFlags trans_flags_;
     TransResult trans_result_;
     int64_t nested_count_;
+    int32_t trans_consistency_type_;
   };
 
 public:
diff --git a/src/storage/transaction/ob_trans_service.cpp b/src/storage/transaction/ob_trans_service.cpp
index 800f0252b801e5b3b15f97a2a2434337f798598f..706be83860f72f64eb98ba343872c8f3de9d1a33 100644
--- a/src/storage/transaction/ob_trans_service.cpp
+++ b/src/storage/transaction/ob_trans_service.cpp
@@ -727,6 +727,11 @@ int ObTransService::handle_sp_end_trans_(const bool is_rollback, ObTransDesc& tr
     need_rollback = true;
     save_ret = OB_TRANS_ROLLBACKED;
     callback = &null_cb;
+  } else if (is_bounded_staleness_read && OB_NOT_NULL(trans_desc.get_part_ctx())) {
+    TRANS_LOG(ERROR, "transaction is_bounded_staleness_read but part_ctx is not null", K(is_rollback), K(trans_desc));
+    need_rollback = true;
+    save_ret = OB_ERR_UNEXPECTED;
+    callback = &null_cb;
   }
 
   TRANS_STAT_COMMIT_ABORT_TRANS_INC(need_rollback, tenant_id);
@@ -748,18 +753,10 @@ int ObTransService::handle_sp_end_trans_(const bool is_rollback, ObTransDesc& tr
                  need_convert_to_dist_trans))) {
     TRANS_LOG(WARN, "sp commit failed", K(ret), K(stmt_expired_time), K(trans_desc));
     if (!need_convert_to_dist_trans) {
-      if (is_bounded_staleness_read) {
-        (void)slave_part_trans_ctx_mgr_.revert_trans_ctx(part_ctx);
-      } else {
-        (void)part_trans_ctx_mgr_.revert_trans_ctx(part_ctx);
-      }
-    }
-  } else {
-    if (is_bounded_staleness_read) {
-      (void)slave_part_trans_ctx_mgr_.revert_trans_ctx(part_ctx);
-    } else {
       (void)part_trans_ctx_mgr_.revert_trans_ctx(part_ctx);
     }
+  } else {
+    (void)part_trans_ctx_mgr_.revert_trans_ctx(part_ctx);
   }
 
   if (OB_SUCC(ret)) {