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

fix LAST_BARRIER_DATA_VERSION not ready for 4_2_5

Browse Source
This commit is contained in:
chinaxing
2024-06-17 11:27:02 +00:00
committed by ob-robot
parent 6096651bf9
commit 82d6756606
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -78,9 +78,15 @@ inline int ObTransService::init_tx_(ObTxDesc &tx,
if (0 == cluster_version && OB_FAIL(GET_MIN_DATA_VERSION(tenant_id_, tx.cluster_version_))) { if (0 == cluster_version && OB_FAIL(GET_MIN_DATA_VERSION(tenant_id_, tx.cluster_version_))) {
TRANS_LOG(WARN, "get min data version fail", K(ret), K(tx)); TRANS_LOG(WARN, "get min data version fail", K(ret), K(tx));
} else if (tx.cluster_version_ < MOCK_DATA_VERSION_4_2_4_0) { } else if (tx.cluster_version_ < MOCK_DATA_VERSION_4_2_4_0) {
if (tx.cluster_version_ == DATA_VERSION_4_2_1_0) {
// FIXME: remove this branch
tx.cluster_version_ = MOCK_DATA_VERSION_4_2_4_0;
TRANS_LOG(WARN, "NEED_REMOVE_NOTICE:4_2_1_0 data version forced to 4_2_4_0");
} else {
ret = OB_ERR_UNEXPECTED; ret = OB_ERR_UNEXPECTED;
TRANS_LOG(WARN, "data version should >= 4_2_4_0", K(ret), K(tx)); TRANS_LOG(WARN, "data version should >= 4_2_4_0", K(ret), K(tx));
} }
}
tx.seq_base_ = common::ObSequence::get_max_seq_no() - 1; tx.seq_base_ = common::ObSequence::get_max_seq_no() - 1;
return ret; return ret;
} }