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

fix load data schema error

Browse Source
This commit is contained in:
Charles0429 2024-10-25 04:51:11 +00:00 committed by ob-robot
parent b06c76337f
commit 4f80ca676b
2 changed files with 14 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/sql/engine/cmd/ob_load_data_impl.cpp
View File

@ -1617,6 +1617,15 @@ int ObLoadDataSPImpl::log_failed_insert_task(ToolBox &box, ObInsertTask &task)
return ret;
}
bool ObLoadDataSPImpl::is_schema_error_need_retry_for_load_data(const int ret_code)
{
return OB_SCHEMA_ERROR == ret_code
|| OB_ERR_WAIT_REMOTE_SCHEMA_REFRESH == ret_code
|| OB_ERR_REMOTE_SCHEMA_NOT_FULL == ret_code
|| OB_SCHEMA_EAGAIN == ret_code
|| OB_SCHEMA_NOT_UPTODATE == ret_code;
}
int ObLoadDataSPImpl::handle_returned_insert_task(ObExecContext &ctx,
ToolBox &box,
ObInsertTask &insert_task,
@ -1678,6 +1687,10 @@ int ObLoadDataSPImpl::handle_returned_insert_task(ObExecContext &ctx,
|| is_partition_change_error(err)
|| is_schema_error(err)) {
task_status = can_retry ? TASK_NEED_RETRY : TASK_FAILED;
task_status = is_schema_error_need_retry_for_load_data(err) ? TASK_NEED_RETRY : task_status;
if (is_schema_error_need_retry_for_load_data(err) && insert_task.retry_times_ % 1000) {
LOG_INFO("load data retry for schema error", K(err));
}
if (OB_FAIL(part_mgr->update_part_location(ctx))) {
LOG_WARN("fail to update location cache", K(ret));
}

1
src/sql/engine/cmd/ob_load_data_impl.h
View File

@ -806,6 +806,7 @@ private:
common::ObIArray<ObLoadTableColumnDesc> &insert_infos,
common::ObString &data_buff,
bool need_online_osg = false);
bool is_schema_error_need_retry_for_load_data(const int ret_code);
// disallow copy
DISALLOW_COPY_AND_ASSIGN(ObLoadDataSPImpl);
// function members