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

vostest pass

Browse Source
This commit is contained in:
tushicheng 2024-06-25 04:46:24 +00:00 committed by ob-robot
parent 5c5e6da6ce
commit 8e6c6a9c4d
3 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
deps/oblib/src/lib/roaringbitmap/ob_rb_utils.cpp vendored
View File

@ -316,7 +316,7 @@ int ObRbUtils::rb_to_string(ObIAllocator &allocator, ObString &rb_bin, ObString
offset += RB_VALUE_COUNT_SIZE;
if (value_count > 0) {
uint32_t *value_ptr = reinterpret_cast<uint32_t *>(rb_bin.ptr() + offset);
std::sort(value_ptr, value_ptr + value_count);
lib::ob_sort(value_ptr, value_ptr + value_count);
for (int i = 0; OB_SUCC(ret) && i < value_count; i++) {
uint32_t value_32 = *reinterpret_cast<const uint32_t*>(rb_bin.ptr() + offset);
offset += sizeof(uint32_t);
@ -337,7 +337,7 @@ int ObRbUtils::rb_to_string(ObIAllocator &allocator, ObString &rb_bin, ObString
offset += RB_VALUE_COUNT_SIZE;
if (value_count > 0) {
uint64_t *value_ptr = reinterpret_cast<uint64_t *>(rb_bin.ptr() + offset);
std::sort(value_ptr, value_ptr + value_count);
lib::ob_sort(value_ptr, value_ptr + value_count);
for (int i = 0; OB_SUCC(ret) && i < value_count; i++) {
uint64_t value_64 = *reinterpret_cast<const uint64_t*>(rb_bin.ptr() + offset);
offset += sizeof(uint64_t);

2
src/sql/engine/px/datahub/components/ob_dh_range_dist_wf.cpp
View File

@ -566,7 +566,7 @@ int RDWinFuncPXPieceMsgCtx::send_whole_msg(common::ObIArray<ObPxSqcMeta *> &sqcs
if (OB_FAIL(wf->rd_generate_patch(*this, eval_ctx))) {
LOG_WARN("generate patch failed", K(ret));
} else {
std::sort(infos_.begin(), infos_.end(), __part_info_cmp_op());
lib::ob_sort(infos_.begin(), infos_.end(), __part_info_cmp_op());
}
RDWinFuncPXWholeMsg *responses = nullptr;
if (OB_SUCC(ret)) {

2
src/sql/engine/window_function/ob_window_function_vec_op.cpp
View File

@ -3677,7 +3677,7 @@ private:
int ObWindowFunctionVecSpec::rd_generate_patch(RDWinFuncPXPieceMsgCtx &msg_ctx, ObEvalCtx &eval_ctx) const
{
int ret = OB_SUCCESS;
std::sort(msg_ctx.infos_.begin(), msg_ctx.infos_.end(), __pby_oby_sort_op(*this));
lib::ob_sort(msg_ctx.infos_.begin(), msg_ctx.infos_.end(), __pby_oby_sort_op(*this));
#ifndef NDEBUG
for (int i = 0; i < msg_ctx.infos_.count(); i++) {
RDWinFuncPXPartialInfo *info = msg_ctx.infos_.at(i);