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)); }