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

Get new das task id when das task retry.

Browse Source
This commit is contained in:
obdev
2023-08-10 10:18:39 +00:00
committed by ob-robot
parent de1f751d37
commit ee614d9292
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/sql/das/ob_data_access_service.cpp
View File

@ -228,6 +228,14 @@ int ObDataAccessService::refresh_task_location_info(ObDASRef &das_ref, ObIDASTas
LOG_WARN("get tablet location failed", K(ret), KPC(tablet_loc)); LOG_WARN("get tablet location failed", K(ret), KPC(tablet_loc));
} else { } else {
task_op.set_ls_id(tablet_loc->ls_id_); task_op.set_ls_id(tablet_loc->ls_id_);
if (!task_op.is_local_task()) {
int64_t task_id;
if (OB_FAIL(MTL(ObDataAccessService*)->get_das_task_id(task_id))) {
LOG_WARN("retry get das task id failed", KR(ret));
} else {
task_op.set_task_id(task_id);
}
}
} }
return ret; return ret;
} }