From 0379aa5bd7590f2bbd2c82f2add93afb56ef45f0 Mon Sep 17 00:00:00 2001 From: chinaxing Date: Mon, 6 Jan 2025 09:45:28 +0000 Subject: [PATCH] [CP] fix reject read uncommited on duplicate table follower --- src/storage/tx/ob_tx_api.cpp | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/src/storage/tx/ob_tx_api.cpp b/src/storage/tx/ob_tx_api.cpp index 502a89256e..9988325aaa 100644 --- a/src/storage/tx/ob_tx_api.cpp +++ b/src/storage/tx/ob_tx_api.cpp @@ -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)); }