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

fix split range

Browse Source
This commit is contained in:
z404289981 2023-09-05 07:41:15 +00:00 committed by ob-robot
parent 013386a767
commit 35d793363d
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/storage/ob_partition_range_spliter.cpp
View File

@ -1296,9 +1296,10 @@ int ObPartitionMultiRangeSpliter::split_multi_ranges(RangeSplitInfoArray &range_
cur_avg_task_size = range_info.total_size_ / range_split_array.count(); cur_avg_task_size = range_info.total_size_ / range_split_array.count();
} }
for (int64_t i = 0; OB_SUCC(ret) && i < range_split_array.count(); i++) { for (int64_t i = 0; OB_SUCC(ret) && i < range_split_array.count(); i++) {
if (sum_size >= avg_task_size if (multi_range_split_array.count() + 1 < expected_task_count
&& (sum_size >= avg_task_size
|| (sum_size >= task_size_low_watermark || (sum_size >= task_size_low_watermark
&& sum_size + cur_avg_task_size >= task_size_high_watermark)) { && sum_size + cur_avg_task_size >= task_size_high_watermark))) {
if (OB_FAIL(merge_and_push_range_array(refra_range_split_array, allocator, if (OB_FAIL(merge_and_push_range_array(refra_range_split_array, allocator,
multi_range_split_array))) { multi_range_split_array))) {
STORAGE_LOG(WARN, "Failed to merge and push split range array", K(ret), K(refra_range_split_array)); STORAGE_LOG(WARN, "Failed to merge and push split range array", K(ret), K(refra_range_split_array));