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

ObSortOp::inner_get_next_batch return OB_ITER_END incorrectly when calculating limit 0 in vectorized scenario

Browse Source
This commit is contained in:
obdev
2023-07-10 03:12:01 +00:00
committed by ob-robot
parent be7c3455c4
commit abb148c4c2
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/sql/engine/sort/ob_sort_op.cpp
View File

@ -520,7 +520,6 @@ int ObSortOp::inner_get_next_batch(const int64_t max_row_cnt)
} else if (topn_cnt <= 0) {
brs_.end_ = true;
brs_.size_ = 0;
ret = OB_ITER_END;
} else if (MY_SPEC.prefix_pos_ > 0) {
if (OB_FAIL(init_prefix_sort(tenant_id, row_count, true, topn_cnt))) {
LOG_WARN("failed to init batch prefix sort", K(ret));
@ -530,14 +529,14 @@ int ObSortOp::inner_get_next_batch(const int64_t max_row_cnt)
LOG_WARN("failed to init batch sort", K(ret));
}
}
if (OB_SUCC(ret)) {
if (OB_SUCC(ret) && !brs_.end_) {
if (OB_FAIL(process_sort_batch())) {
LOG_WARN("process sort failed", K(ret));
}
}
}
if (OB_SUCC(ret)) {
if (OB_SUCC(ret) && !brs_.end_) {
clear_evaluated_flag();
if (OB_FAIL((this->*read_batch_func_)(std::min(max_row_cnt, MY_SPEC.max_batch_size_)))) {
LOG_WARN("get next row failed");