update column_info_simplified
This commit is contained in:
@ -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(),
|
||||
|
||||
@ -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
|
||||
|
||||
Reference in New Issue
Block a user