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

fix for hashgroupby all_rows_active wrong value

Browse Source
This commit is contained in:
lucky-sinx
2024-07-04 05:21:58 +00:00
committed by ob-robot
parent 3449f775a6
commit 6a701acb85
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/sql/engine/aggregate/ob_hash_groupby_vec_op.cpp
View File

@ -2099,7 +2099,12 @@ int ObHashGroupByVecOp::by_pass_prepare_one_batch(const int64_t batch_size)
} }
} }
if (OB_FAIL(ret) || no_non_distinct_aggr_) { if (OB_FAIL(ret) || no_non_distinct_aggr_) {
if (last_group && no_non_distinct_aggr_) {
// in bypass && last_group && no_non_distinct_aggr_, brs_.skip_ will be set_all (all skip)
brs_.all_rows_active_ = false;
} else {
brs_.all_rows_active_ = by_pass_child_brs_->all_rows_active_; brs_.all_rows_active_ = by_pass_child_brs_->all_rows_active_;
}
} else if (OB_UNLIKELY(by_pass_batch_size_ <= 0)) { } else if (OB_UNLIKELY(by_pass_batch_size_ <= 0)) {
ret = OB_ERR_UNEXPECTED; ret = OB_ERR_UNEXPECTED;
LOG_WARN("by pass group row is not init", K(ret), K(by_pass_batch_size_)); LOG_WARN("by pass group row is not init", K(ret), K(by_pass_batch_size_));