diff --git a/src/storage/ob_partition_range_spliter.cpp b/src/storage/ob_partition_range_spliter.cpp index ab7b54ecfa..2e37820a3f 100644 --- a/src/storage/ob_partition_range_spliter.cpp +++ b/src/storage/ob_partition_range_spliter.cpp @@ -607,9 +607,7 @@ int ObPartitionParallelRanger::split_ranges( if (IS_NOT_INIT) { ret = OB_NOT_INIT; STORAGE_LOG(WARN, "ObPartitionParallelRanger is not init", K(ret)); - } else if (sample_cnt_ == 0 || parallel_target_count_ == 1 - || parallel_target_count_ > total_endkey_cnt_ + 1) { - // cannot afford specified parallel target count, back into single whole range + } else if (sample_cnt_ == 0 || parallel_target_count_ == 1) { if (OB_FAIL(construct_single_range(allocator, store_range_->get_start_key(), store_range_->get_end_key(), diff --git a/src/storage/ob_storage_schema.cpp b/src/storage/ob_storage_schema.cpp index 5074630b89..455447b7e0 100644 --- a/src/storage/ob_storage_schema.cpp +++ b/src/storage/ob_storage_schema.cpp @@ -1579,6 +1579,10 @@ void ObStorageSchema::update_column_cnt(const int64_t input_col_cnt) { column_cnt_ = MAX(column_cnt_, input_col_cnt); store_column_cnt_ = MAX(store_column_cnt_, input_col_cnt); + if (column_cnt_ != column_array_.count()) { + column_info_simplified_ = true; + STORAGE_LOG(INFO, "update column cnt", K(column_cnt_), K(store_column_cnt_), K(column_cnt_), K(column_array_.count())); + } } } // namespace storage