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

adjust max_batch_size for hash gby

Browse Source
This commit is contained in:
18523270951@163.com 2024-05-23 08:16:29 +00:00 committed by ob-robot
parent 5eb7245307
commit 42bf26214d
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/sql/engine/aggregate/ob_hash_groupby_op.cpp
View File

@ -1538,7 +1538,7 @@ int ObHashGroupByOp::inner_get_next_batch(const int64_t max_row_cnt)
curr_group_id_ = 0;
bypass_ctrl_.start_by_pass();
LOG_TRACE("force by pass open");
} else if (OB_FAIL(load_data_batch(op_max_batch_size))) {
} else if (OB_FAIL(load_data_batch(MY_SPEC.max_batch_size_))) {
LOG_WARN("load data failed", K(ret));
} else {
curr_group_id_ = 0;
@ -1558,7 +1558,7 @@ int ObHashGroupByOp::inner_get_next_batch(const int64_t max_row_cnt)
brs_.size_ = 0;
reset();
} else {
if (OB_FAIL(load_data_batch(op_max_batch_size))) {
if (OB_FAIL(load_data_batch(MY_SPEC.max_batch_size_))) {
LOG_WARN("load data failed", K(ret));
} else {
op_monitor_info_.otherstat_3_value_ =
@ -1586,7 +1586,7 @@ int ObHashGroupByOp::inner_get_next_batch(const int64_t max_row_cnt)
LOG_WARN("failed to restart", K(ret));
} else if (OB_FAIL(init_by_pass_group_batch_item())) {
LOG_WARN("failed to init by pass row", K(ret));
} else if (OB_FAIL(load_data_batch(op_max_batch_size))) {
} else if (OB_FAIL(load_data_batch(MY_SPEC.max_batch_size_))) {
LOG_WARN("failed to laod data", K(ret));
} else if (curr_group_id_ >= local_group_rows_.size()) {
iter_end_ = true;

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

@ -936,7 +936,7 @@ int ObHashGroupByVecOp::inner_get_next_batch(const int64_t max_row_cnt)
curr_group_id_ = 0;
bypass_ctrl_.start_by_pass();
LOG_TRACE("force by pass open");
} else if (OB_FAIL(load_data_batch(op_max_batch_size))) {
} else if (OB_FAIL(load_data_batch(MY_SPEC.max_batch_size_))) {
LOG_WARN("load data failed", K(ret));
} else {
curr_group_id_ = 0;
@ -956,7 +956,7 @@ int ObHashGroupByVecOp::inner_get_next_batch(const int64_t max_row_cnt)
brs_.size_ = 0;
reset(false);
} else {
if (OB_FAIL(load_data_batch(op_max_batch_size))) {
if (OB_FAIL(load_data_batch(MY_SPEC.max_batch_size_))) {
LOG_WARN("load data failed", K(ret));
} else {
op_monitor_info_.otherstat_3_value_ =
@ -988,7 +988,7 @@ int ObHashGroupByVecOp::inner_get_next_batch(const int64_t max_row_cnt)
LOG_WARN("failed to restart", K(ret));
} else if (OB_FAIL(init_by_pass_group_batch_item())) {
LOG_WARN("failed to init by pass row", K(ret));
} else if (OB_FAIL(load_data_batch(op_max_batch_size))) {
} else if (OB_FAIL(load_data_batch(MY_SPEC.max_batch_size_))) {
LOG_WARN("failed to laod data", K(ret));
} else if (curr_group_id_ >= local_group_rows_.size()) {
iter_end_ = true;