From d98f89683d993c8eee7844dec71b8d35746f3ead Mon Sep 17 00:00:00 2001 From: "18523270951@163.com" <18523270951@163.com> Date: Tue, 9 May 2023 18:10:22 +0000 Subject: [PATCH] fix merge union get wrong result when batch_size decrease --- src/sql/engine/set/ob_merge_union_op.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/sql/engine/set/ob_merge_union_op.cpp b/src/sql/engine/set/ob_merge_union_op.cpp index e563a6f5ff..be9584166c 100644 --- a/src/sql/engine/set/ob_merge_union_op.cpp +++ b/src/sql/engine/set/ob_merge_union_op.cpp @@ -637,7 +637,7 @@ int ObMergeUnionOp::do_strict_distinct_vectorize(ObOperator &child_op, int ret = OB_SUCCESS; found_valid_row = false; //if compare_row is nullptr, means we do row compare in a batch, get values from expr - if (OB_NOT_NULL(op_info.op_brs_) && OB_SUCC(ret) && op_info.op_idx_ < batch_size) { + if (OB_NOT_NULL(op_info.op_brs_) && OB_SUCC(ret) && op_info.op_idx_ < op_info.op_brs_->size_) { for (int64_t i = op_info.op_idx_; OB_SUCC(ret) && !found_valid_row && i < op_info.op_brs_->size_; ++i, ++op_info.op_idx_) {