hcq/oceanbase
hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

[CP] fix reject read uncommited on duplicate table follower

Browse Source
This commit is contained in:
chinaxing 2025-01-06 09:45:28 +00:00 committed by ob-robot
parent 17c3a1dc44
commit 0379aa5bd7
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/storage/tx/ob_tx_api.cpp
View File

@ -684,8 +684,7 @@ int ObTransService::get_read_snapshot(ObTxDesc &tx,
}
if (tx.state_ != ObTxDesc::State::IDLE) {
ARRAY_FOREACH(tx.parts_, i) {
if (!tx.parts_[i].is_clean() &&
OB_FAIL(snapshot.parts_.push_back(ObTxLSEpochPair(tx.parts_[i].id_, tx.parts_[i].epoch_)))) {
if (OB_FAIL(snapshot.parts_.push_back(ObTxLSEpochPair(tx.parts_[i].id_, tx.parts_[i].epoch_)))) {
TRANS_LOG(WARN, "push snapshot parts fail", K(ret), K(tx), K(snapshot));
}
}
@ -745,7 +744,7 @@ int ObTransService::get_ls_read_snapshot(ObTxDesc &tx,
}
if (tx.state_ != ObTxDesc::State::IDLE) {
ARRAY_FOREACH(tx.parts_, i) {
if (tx.parts_[i].id_ == lsid && !tx.parts_[i].is_clean()) {
if (tx.parts_[i].id_ == lsid) {
if (OB_FAIL(snapshot.parts_.push_back(ObTxLSEpochPair(lsid, tx.parts_[i].epoch_)))) {
TRANS_LOG(WARN, "push lsid to snapshot.parts fail", K(ret), K(lsid), K(tx));
}