fix external table bug

This commit is contained in:
wjhh2008
2024-06-26 05:36:10 +00:00
committed by ob-robot
parent d80c469834
commit da2b93fad1
2 changed files with 5 additions and 2 deletions

View File

@ -395,7 +395,7 @@ int ObExternalTableUtils::calc_assigned_files_to_sqcs(
struct SqcFileSetCmp { struct SqcFileSetCmp {
bool operator()(const SqcFileSet &l, const SqcFileSet &r) { bool operator()(const SqcFileSet &l, const SqcFileSet &r) {
return l.total_file_size_ < r.total_file_size_; return l.total_file_size_ > r.total_file_size_;
} }
int get_error_code() { return OB_SUCCESS; } int get_error_code() { return OB_SUCCESS; }
}; };

View File

@ -3113,7 +3113,10 @@ int ObCreateTableResolver::resolve_index_name(
int ObCreateTableResolver::resolve_external_table_format_early(const ParseNode *node) int ObCreateTableResolver::resolve_external_table_format_early(const ParseNode *node)
{ {
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
if (OB_NOT_NULL(node)) { if (OB_ISNULL(node)) {
ret = OB_NOT_SUPPORTED;
LOG_USER_ERROR(OB_NOT_SUPPORTED, "format");
} else {
if (T_TABLE_OPTION_LIST != node->type_) { if (T_TABLE_OPTION_LIST != node->type_) {
ret = OB_ERR_UNEXPECTED; ret = OB_ERR_UNEXPECTED;
LOG_WARN("invalid argument.", K(ret)); LOG_WARN("invalid argument.", K(ret));