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

Change the return code of the oss direct load path

Browse Source
This commit is contained in:
obdev
2024-06-28 11:53:43 +00:00
committed by ob-robot
parent 08add2abda
commit 18bdc08688
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/sql/resolver/cmd/ob_load_data_resolver.cpp
View File

@ -667,7 +667,12 @@ int ObLoadDataResolver::resolve_filename(ObLoadDataStmt *load_stmt, ParseNode *n
ret = OB_INVALID_ARGUMENT;
LOG_USER_ERROR(OB_INVALID_ARGUMENT, "file name or access key");
} else if (OB_FAIL(load_args.access_info_.set(load_args.file_name_.ptr(), storage_info.ptr()))) {
LOG_WARN("failed to set access info", K(ret));
if (ret == OB_INVALID_BACKUP_DEST) {
ret = OB_INVALID_ARGUMENT;
LOG_USER_ERROR(OB_INVALID_ARGUMENT, "access info");
} else {
LOG_WARN("failed to set access info", K(ret), K(load_args.file_name_), K(storage_info));
}
} else if (OB_ISNULL(file_ptr = temp_file_name.reverse_find('/'))) {
ret = OB_INVALID_ARGUMENT;
LOG_USER_ERROR(OB_INVALID_ARGUMENT, "file name");
@ -708,8 +713,8 @@ int ObLoadDataResolver::resolve_filename(ObLoadDataStmt *load_stmt, ParseNode *n
}
}
if (OB_SUCC(ret) && load_args.file_iter_.count() == 0) {
ret = OB_BACKUP_FILE_NOT_EXIST;
LOG_WARN("No matches found for pattern", K(ret), K(pattern));
ret = OB_FILE_NOT_EXIST;
LOG_WARN("files not exists", K(ret), K(pattern));
}
}
} else {