Fix the correctness of merge gby

2024-09-03 14:13:33 +00:00 · 2024-09-03 14:13:33 +00:00 · 2070bae744
commit 2070bae744
parent 79ab9377d4
1 changed files with 4 additions and 0 deletions
--- a/src/sql/engine/aggregate/ob_merge_groupby_vec_op.cpp
+++ b/src/sql/engine/aggregate/ob_merge_groupby_vec_op.cpp
@ -1487,6 +1487,10 @@ int ObMergeGroupByVecOp::process_batch(const ObBatchRows &brs)
    group_processor_.prepare_process_next_batch();
    group_end_idx = brs.size_;
    while (OB_SUCC(ret) && !is_iter_end && idx < brs.size_) {
+      if (brs.skip_->at(idx)) {
+        ++idx;
+        continue;
+      }
      found_new_group = false;
      if (nullptr == cur_aggr_row_) {
        batch_info_guard.set_batch_idx(idx);