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

fix backup concurrency bug leading to -4015

Browse Source
This commit is contained in:
oceanoverflow
2022-12-09 03:38:29 +00:00
committed by ob-robot
parent 6647f60965
commit 9b8edfcf0c
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/storage/backup/ob_backup_task.cpp
View File

@ -2097,8 +2097,6 @@ int ObPrefetchBackupInfoTask::inner_process_()
} else if (OB_FAIL(get_need_copy_item_list_(
sorted_items, need_copy_item_list, no_need_copy_item_list, no_need_copy_macro_index_list))) {
LOG_WARN("failed to check need reuse", K(ret), K(sorted_items));
} else if (OB_FAIL(task_mgr_->receive(task_id, need_copy_item_list))) {
LOG_WARN("failed to receive items", K(ret), K(task_id), K(need_copy_item_list));
} else if (OB_FAIL(ls_backup_ctx_->tablet_stat_.mark_items_pending(backup_data_type_, need_copy_item_list))) {
LOG_WARN("failed to mark items pending", K(ret), K_(backup_data_type), K(need_copy_item_list));
} else if (OB_FAIL(ls_backup_ctx_->tablet_stat_.mark_items_reused(
@ -2108,6 +2106,8 @@ int ObPrefetchBackupInfoTask::inner_process_()
K_(backup_data_type),
K(no_need_copy_item_list),
K(no_need_copy_macro_index_list));
} else if (OB_FAIL(task_mgr_->receive(task_id, need_copy_item_list))) {
LOG_WARN("failed to receive items", K(ret), K(task_id), K(need_copy_item_list));
} else {
LOG_INFO(
"receive backup items", K(task_id), K_(backup_data_type), "count", need_copy_item_list.count(), K_(param));