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

[CP] fix execute import ddl but return task exist

Browse Source
This commit is contained in:
wxhwang
2024-02-06 22:47:56 +00:00
committed by ob-robot
parent 52586a421f
commit 34589fbf65
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/rootserver/restore/ob_import_table_job_scheduler.cpp
View File

@ -624,7 +624,13 @@ int ObImportTableTaskScheduler::gen_import_ddl_task_()
} else if (OB_FAIL(construct_import_table_arg_(arg))) { } else if (OB_FAIL(construct_import_table_arg_(arg))) {
LOG_WARN("failed to construct import table arg", K(ret)); LOG_WARN("failed to construct import table arg", K(ret));
} else if (OB_FAIL(ObDDLServerClient::execute_recover_restore_table(arg))) { } else if (OB_FAIL(ObDDLServerClient::execute_recover_restore_table(arg))) {
if (OB_ENTRY_EXIST == ret) {
// old and new leader both execute import ddl at the same time.
ret = OB_EAGAIN;
LOG_WARN("import ddl task exist, try again", K(ret), K(arg));
} else {
LOG_WARN("fail to start import table", K(ret), K(arg)); LOG_WARN("fail to start import table", K(ret), K(arg));
}
} else { } else {
LOG_INFO("[IMPORT_TABLE]succeed execute_recover_restore_table", KPC_(import_task), K(arg)); LOG_INFO("[IMPORT_TABLE]succeed execute_recover_restore_table", KPC_(import_task), K(arg));
} }