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

Fix transfer backfill tx mistake error.

Browse Source
This commit is contained in:
godyangfight
2024-07-17 11:22:23 +00:00
committed by ob-robot
parent 25dec5d5f3
commit 5f6497f95c
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/storage/high_availability/ob_tablet_backfill_tx.cpp
View File

@ -947,6 +947,14 @@ int ObTabletBackfillTXTask::add_ready_sstable_into_table_mgr_(
LOG_WARN("failed to get latest tablet status", K(ret), KP(tablet)); LOG_WARN("failed to get latest tablet status", K(ret), KP(tablet));
} else if (FALSE_IT(transfer_start_scn = user_data.transfer_scn_)) { } else if (FALSE_IT(transfer_start_scn = user_data.transfer_scn_)) {
} else if (FALSE_IT(transfer_seq = tablet->get_tablet_meta().transfer_info_.transfer_seq_)) { } else if (FALSE_IT(transfer_seq = tablet->get_tablet_meta().transfer_info_.transfer_seq_)) {
} else if (!transfer_start_scn.is_valid()) {
if (tablet_info_.is_committed_) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("transfer transaction is committed but transfer start scn is invalid, unexpected", K(ret), K(tablet_info_), K(user_data));
} else {
ret = OB_EAGAIN;
LOG_WARN("transfer start scn is invalid, may transfer transaction rollback, need retry", K(ret), K(tablet_info_), K(user_data));
}
} else { } else {
for (int64_t i = 0; OB_SUCC(ret) && i < non_backfill_sstable.count(); ++i) { for (int64_t i = 0; OB_SUCC(ret) && i < non_backfill_sstable.count(); ++i) {
ObTableHandleV2 &table_handle = non_backfill_sstable.at(i); ObTableHandleV2 &table_handle = non_backfill_sstable.at(i);