提交 53b1e663 编写于 作者: Z zh0 提交者: wangzelin.wzl

fix discard participants bug

上级 13f6b30b
...@@ -2421,8 +2421,10 @@ int ObTransService::end_stmt(bool is_rollback, bool is_incomplete, const ObParti ...@@ -2421,8 +2421,10 @@ int ObTransService::end_stmt(bool is_rollback, bool is_incomplete, const ObParti
// or which no need for creating context (has_epoch) // or which no need for creating context (has_epoch)
if (!is_rollback) { if (!is_rollback) {
for (int64_t i = 0; OB_SUCC(ret) && i < cur_stmt_all_participants.count(); i++) { for (int64_t i = 0; OB_SUCC(ret) && i < cur_stmt_all_participants.count(); i++) {
// if participant is pg, merge commit list immediately
if (is_contain(epoch_participants, cur_stmt_all_participants.at(i)) && if (is_contain(epoch_participants, cur_stmt_all_participants.at(i)) &&
!is_contain(discard_participants, cur_stmt_all_participants.at(i))) { (cur_stmt_all_participants.at(i).is_pg() ||
!is_contain(discard_participants, cur_stmt_all_participants.at(i)))) {
if (OB_FAIL(real_stmt_participants.push_back(cur_stmt_all_participants.at(i)))) { if (OB_FAIL(real_stmt_participants.push_back(cur_stmt_all_participants.at(i)))) {
TRANS_LOG(WARN, "push back error", KR(ret), K(cur_stmt_all_participants), K(trans_desc)); TRANS_LOG(WARN, "push back error", KR(ret), K(cur_stmt_all_participants), K(trans_desc));
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册