do not rollback if is_bounded_staleness_read() when end_nested_stmt()

bf9c4cfa · obdev · wangzelin.wzl · cd677961 · bf9c4cfa
隐藏空白更改
内联并排

Showing with 3 addition and 2 deletion

src/storage/transaction/ob_trans_service.cpp src/storage/transaction/ob_trans_service.cpp +3 -2

未找到文件。
--- a/src/storage/transaction/ob_trans_service.cpp
+++ b/src/storage/transaction/ob_trans_service.cpp
@@ -833,8 +833,9 @@ int ObTransService::end_nested_stmt(
  } else if (OB_UNLIKELY(trans_desc.need_rollback())) {
    ret = OB_TRANS_NEED_ROLLBACK;
    TRANS_LOG(WARN, "transaction need rollback", K(ret), K(trans_desc));
-  } else if (is_rollback &&
+  } else if (is_rollback
-             OB_FAIL(do_dist_rollback_(trans_desc, trans_desc.get_stmt_min_sql_no() - 1, participants))) {
+             && !trans_desc.is_bounded_staleness_read()
+             && OB_FAIL(do_dist_rollback_(trans_desc, trans_desc.get_stmt_min_sql_no() - 1, participants))) {
    TRANS_LOG(WARN, "fail to do dist rollback", K(ret), K(trans_desc), K(participants));
  }