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

remove backup meta timeout

Browse Source
This commit is contained in:
hamstersox
2023-02-13 13:14:46 +00:00
committed by ob-robot
parent 0a4df972e8
commit bd3408f14a
1 changed files with 1 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
src/rootserver/backup/ob_backup_data_set_task_mgr.cpp
View File

@ -387,26 +387,8 @@ int ObBackupSetTaskMgr::backup_user_meta_()
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
ObArray<ObBackupLSTaskAttr> ls_task; ObArray<ObBackupLSTaskAttr> ls_task;
int64_t finish_cnt = 0; int64_t finish_cnt = 0;
uint64_t backup_meta_start_ts = set_task_attr_.user_ls_start_scn_.convert_to_ts();
int64_t backup_user_meta_timeout = OB_MAX_BACKUP_META_TIMEOUT;
#ifdef ERRSIM
backup_user_meta_timeout = GCONF.errsim_max_backup_meta_retry_time_interval;
#endif
DEBUG_SYNC(BEFORE_BACKUP_UESR_META); DEBUG_SYNC(BEFORE_BACKUP_UESR_META);
if (backup_meta_start_ts + backup_user_meta_timeout < ObTimeUtility::current_time()) { if (OB_FAIL(ObBackupLSTaskOperator::get_ls_tasks(*sql_proxy_, job_attr_->job_id_, job_attr_->tenant_id_, false/*update*/, ls_task))) {
// backup meta overtime, need change meta turn.
// get new ls list, and do backup meta in new turn.
if (OB_FAIL(enable_transfer_())) {
LOG_WARN("fail to enable transfer", K(ret));
} else if (OB_FAIL(change_meta_turn_())) {
LOG_WARN("fail to change meta turn", K(ret), K(set_task_attr_));
} else {
ROOTSERVICE_EVENT_ADD("backup_data", "backup meta chang turn", "tenant_id",
job_attr_->tenant_id_, "job_id", job_attr_->job_id_, "task_id", set_task_attr_.task_id_);
}
} else if (OB_FAIL(ObBackupLSTaskOperator::get_ls_tasks(*sql_proxy_, job_attr_->job_id_, job_attr_->tenant_id_, false/*update*/, ls_task))) {
LOG_WARN("[DATA_BACKUP]failed to get log stream tasks", K(ret), "job_id", job_attr_->job_id_, "tenant_id", job_attr_->tenant_id_); LOG_WARN("[DATA_BACKUP]failed to get log stream tasks", K(ret), "job_id", job_attr_->job_id_, "tenant_id", job_attr_->tenant_id_);
} else if (ls_task.empty()) { } else if (ls_task.empty()) {
ret = OB_ERR_UNEXPECTED; ret = OB_ERR_UNEXPECTED;