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

Fix the problem of correctness caused by partition sort error code coverage

Browse Source
This commit is contained in:
obdev 2024-04-09 05:37:46 +00:00 committed by ob-robot
parent b1f1be5032
commit 69541b8b16
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/sql/engine/sort/ob_sort_op_impl.cpp
View File

@ -1927,7 +1927,7 @@ int ObSortOpImpl::sort_inmem_data()
heap_nodes_.reuse(); heap_nodes_.reuse();
do_partition_topn_sort(); do_partition_topn_sort();
} else if (part_cnt_ > 0) { } else if (part_cnt_ > 0) {
do_partition_sort(*rows_, begin, rows_->count()); OZ(do_partition_sort(*rows_, begin, rows_->count()));
} else if (enable_encode_sortkey_) { } else if (enable_encode_sortkey_) {
bool can_encode = true; bool can_encode = true;
ObAdaptiveQS aqs(*rows_, mem_context_->get_malloc_allocator()); ObAdaptiveQS aqs(*rows_, mem_context_->get_malloc_allocator());

2
src/sql/engine/sort/ob_sort_vec_op_impl.ipp
View File

@ -1417,7 +1417,7 @@ int ObSortVecOpImpl<Compare, Store_Row, has_addon>::sort_inmem_data()
} }
} }
if (part_cnt_ > 0) { if (part_cnt_ > 0) {
do_partition_sort(*sk_row_meta_, *rows_, begin, rows_->count()); OZ(do_partition_sort(*sk_row_meta_, *rows_, begin, rows_->count()));
} else if (enable_encode_sortkey_) { } else if (enable_encode_sortkey_) {
bool can_encode = true; bool can_encode = true;
ObAdaptiveQS<Store_Row> aqs(*rows_, *sk_row_meta_, mem_context_->get_malloc_allocator()); ObAdaptiveQS<Store_Row> aqs(*rows_, *sk_row_meta_, mem_context_->get_malloc_allocator());