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

fix external table bug

Browse Source
This commit is contained in:
wjhh2008
2024-02-09 01:07:04 +00:00
committed by ob-robot
parent 56fab289be
commit 4d704cfacd
1 changed files with 13 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
src/sql/engine/table/ob_external_table_access_service.cpp
View File

@ -85,7 +85,8 @@ int ObExternalDataAccessDriver::get_file_size(const ObString &url, int64_t &file
int temp_ret = device_handle_->stat(to_cstring(url), statbuf);
if (OB_SUCCESS != temp_ret) {
file_size = -1;
if (OB_BACKUP_FILE_NOT_EXIST == temp_ret) {
if (OB_BACKUP_FILE_NOT_EXIST == temp_ret
|| OB_IO_ERROR == temp_ret) {
file_size = -1;
} else {
ret = temp_ret;
@ -250,7 +251,17 @@ int ObExternalDataAccessDriver::get_file_list(const ObString &path,
}
} else if (get_storage_type() == OB_STORAGE_FILE) {
ObSEArray<ObString, 4> file_dirs;
OZ (file_dirs.push_back(path));
bool is_dir = false;
ObString path_without_prifix;
path_without_prifix = path;
path_without_prifix += strlen(OB_FILE_PREFIX);
OZ (FileDirectoryUtils::is_directory(to_cstring(path_without_prifix), is_dir));
if (!is_dir) {
LOG_WARN("external location is not a directory", K(path_without_prifix));
} else {
OZ (file_dirs.push_back(path));
}
for (int64_t i = 0; OB_SUCC(ret) && i < file_dirs.count(); i++) {
ObString file_dir = file_dirs.at(i);
ObLocalFileListArrayOpWithFilter dir_op(file_dirs, file_dir, path, NULL, allocator);