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

fix restore failed

Browse Source
This commit is contained in:
wxhwang
2023-03-09 03:45:55 +00:00
committed by ob-robot
parent d709d1d765
commit d7ae67927e
1 changed files with 18 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/share/backup/ob_archive_store.cpp
View File

@ -1258,6 +1258,24 @@ int ObArchiveStore::get_piece_paths_in_range(const SCN &start_scn, const SCN &en
} }
if (cur.start_scn_ >= end_scn) { if (cur.start_scn_ >= end_scn) {
// this piece may be required for restore, consider the following case.
// Piece#1 : <2022-06-01 06:00:00, 2022-06-02 05:00:00, 2022-06-02 06:00:00>
// Piece#2 : <2022-06-02 06:00:00, 2022-06-03 05:00:00, 2022-06-03 06:00:00>
// Piece#3 : <2022-06-03 06:00:00, 2022-06-03 10:00:00, 2022-06-04 06:00:00>
// If 'end_scn' is indicated to ' 2022-06-03 05:30:00', Piece#3 is required.
if (!pieces.empty()) {
const ObTenantArchivePieceAttr &prev = piece_whole_info.his_frozen_pieces_.at(last_piece_idx);
// If pieces are not enough, and current piece is continous with previous one.
if (prev.end_scn_ == cur.start_scn_ && prev.checkpoint_scn_ < end_scn) {
if (OB_FAIL(ObArchivePathUtil::get_piece_dir_path(dest, cur.key_.dest_id_, cur.key_.round_id_, cur.key_.piece_id_, piece_path))) {
LOG_WARN("failed to get piece path", K(ret), K(dest), K(cur));
} else if (OB_FAIL(pieces.push_back(piece_path))) {
LOG_WARN("fail to push back path", K(ret), K(piece_path));
} else {
last_piece_idx = i;
}
}
}
break; break;
} }