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

fix archive

Browse Source
This commit is contained in:
wxhwang
2023-07-14 10:48:02 +00:00
committed by ob-robot
parent ac80c1f662
commit a9101a2a2c
1 changed files with 10 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/share/backup/ob_archive_checkpoint.cpp
View File

@ -341,12 +341,14 @@ int ObDestRoundCheckpointer::generate_one_piece_(const ObTenantArchiveRoundAttr
LOG_WARN("failed to calc piece base ts", K(ret), K(new_round_info), K(piece_id));
} else if (OB_FAIL(ObTenantArchiveMgr::decide_piece_end_scn(new_round_info.start_scn_, new_round_info.base_piece_id_, new_round_info.piece_switch_interval_, piece_id, piece.piece_info_.end_scn_))) {
LOG_WARN("failed to calc piece end ts", K(ret), K(new_round_info), K(piece_id));
} else if (OB_FAIL(piece.piece_info_.set_path(new_round_info.path_))) {
LOG_WARN("failed to set path", K(ret), K(piece), K(new_round_info));
}
// stat data amount and checkpoint ts for current piece.
const ObArray<ObLSDestRoundSummary> &ls_round_list = summary.ls_round_list_;
piece.piece_info_.checkpoint_scn_ = SCN::max_scn();
piece.piece_info_.max_scn_ = SCN::min_scn();
piece.piece_info_.max_scn_ = piece.piece_info_.start_scn_;
for (int64_t i = 0; OB_SUCC(ret) && i < ls_round_list.count(); i++) {
const ObLSDestRoundSummary &ls_round = ls_round_list.at(i);
// search the piece
@ -365,7 +367,7 @@ int ObDestRoundCheckpointer::generate_one_piece_(const ObTenantArchiveRoundAttr
gen_ls_piece.max_lsn_ = ls_piece.max_lsn_;
gen_ls_piece.input_bytes_ = ls_piece.input_bytes_;
gen_ls_piece.output_bytes_ = ls_piece.output_bytes_;
gen_ls_piece.is_ls_deleted_ = ls_round.is_deleted_;
gen_ls_piece.is_ls_deleted_ = false;
// fill piece
@ -375,6 +377,10 @@ int ObDestRoundCheckpointer::generate_one_piece_(const ObTenantArchiveRoundAttr
} else if (last_piece) {
// If the ls is deleted, and this is the last piece. It should not
// affect the checkpoint_scn.
// Mark the last piece deleted for deleted ls. For example, piece 10 and 11 is found of
// a deleted ls for current checkpoint, piece 10 is not marked with deleted, but piece 11
// is marked with deleted.
gen_ls_piece.is_ls_deleted_ = true;
} else {
piece.piece_info_.checkpoint_scn_ = MIN(piece.piece_info_.checkpoint_scn_, ls_piece.checkpoint_scn_);
}
@ -383,10 +389,8 @@ int ObDestRoundCheckpointer::generate_one_piece_(const ObTenantArchiveRoundAttr
piece.piece_info_.input_bytes_ += ls_piece.input_bytes_;
piece.piece_info_.output_bytes_ += ls_piece.output_bytes_;
if (FAILEDx(piece.piece_info_.set_path(new_round_info.path_))) {
LOG_WARN("failed to set path", K(ret), K(piece), K(gen_ls_piece), K(new_round_info));
} else if (OB_FAIL(piece.ls_piece_list_.push_back(gen_ls_piece))) {
LOG_WARN("failed to push backup ls piece", K(ret), K(piece), K(gen_ls_piece));
if (FAILEDx(piece.ls_piece_list_.push_back(gen_ls_piece))) {
LOG_WARN("failed to push back ls piece", K(ret), K(piece), K(gen_ls_piece));
}
}
}