diff --git a/src/storage/backup/ob_backup_task.cpp b/src/storage/backup/ob_backup_task.cpp index 13fe6b9e361771f1c6d279d1bf85a999907cb411..0a53066bf7feb6b7df19817725e125d329d59be7 100644 --- a/src/storage/backup/ob_backup_task.cpp +++ b/src/storage/backup/ob_backup_task.cpp @@ -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));