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

online ddl tablet on demand.

Browse Source
This commit is contained in:
obdev
2024-02-09 08:10:52 +00:00
committed by ob-robot
parent 7c310666c6
commit 1a85bf7025
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/storage/ls/ob_ls_ddl_log_handler.cpp
View File

@ -228,13 +228,19 @@ int ObLSDDLLogHandler::online()
} else { } else {
while (OB_SUCC(ret)) { while (OB_SUCC(ret)) {
ObTabletHandle tablet_handle; ObTabletHandle tablet_handle;
if (OB_FAIL(tablet_iter.get_next_tablet(tablet_handle))) { ObDDLKvMgrHandle ddl_kv_mgr_handle;
if (OB_FAIL(tablet_iter.get_next_ddl_kv_mgr(ddl_kv_mgr_handle))) {
if (OB_ITER_END == ret) { if (OB_ITER_END == ret) {
ret = OB_SUCCESS; ret = OB_SUCCESS;
break; break;
} else { } else {
LOG_WARN("get next tablet failed", K(ret)); LOG_WARN("failed to get next ddl kv mgr", K(ret));
} }
} else if (OB_UNLIKELY(!ddl_kv_mgr_handle.is_valid())) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("invalid tablet handle", K(ret), K(ddl_kv_mgr_handle));
} else if (OB_FAIL(ls_->get_tablet(ddl_kv_mgr_handle.get_obj()->get_tablet_id(), tablet_handle))) {
LOG_WARN("get tablet handle failed", K(ret), KPC(ddl_kv_mgr_handle.get_obj()));
} else if (OB_FAIL(tablet_handle.get_obj()->start_direct_load_task_if_need())) { } else if (OB_FAIL(tablet_handle.get_obj()->start_direct_load_task_if_need())) {
LOG_WARN("start ddl if need failed", K(ret)); LOG_WARN("start ddl if need failed", K(ret));
} }