fix shared hash join overestimate part count leads OOM

This commit is contained in:
18523270951@163.com
2023-05-17 07:46:35 +00:00
committed by ob-robot
parent 6d7334a245
commit 20897d4e31

View File

@ -1516,9 +1516,6 @@ int ObHashJoinOp::calc_basic_info(bool global_info)
LOG_WARN("failed to get px size", K(ret));
} else {
LOG_TRACE("trace left row count", K(row_count));
if (is_shared_) {
row_count *= (static_cast<ObHashJoinInput*>(input_))->get_sqc_thread_count();
}
if (row_count < MIN_ROW_COUNT) {
row_count = MIN_ROW_COUNT;
}
@ -1534,9 +1531,6 @@ int ObHashJoinOp::calc_basic_info(bool global_info)
// it need to be considered swapping left and right
input_size = left_batch_->get_size_on_disk();
row_count = left_batch_->get_row_count_on_disk();
if (is_shared_) {
row_count *= (static_cast<ObHashJoinInput*>(input_))->get_sqc_thread_count();
}
}
}
} else if (RECURSIVE == hj_processor_) {