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

do not read right for shared hj when left is empty

Browse Source
This commit is contained in:
18523270951@163.com 2024-10-10 08:28:49 +00:00 committed by ob-robot
parent 7e801ab630
commit f7732c8b54
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/sql/engine/join/hash_join/ob_hash_join_vec_op.cpp
View File

@ -630,7 +630,7 @@ int ObHashJoinVecOp::process_left(bool &need_not_read_right)
}
if (OB_SUCC(ret)
&& !is_shared_
&& (!is_shared_ || 0 == cur_join_table_->get_row_count())
&& ((0 == num_left_rows
&& RIGHT_ANTI_JOIN != MY_SPEC.join_type_
&& RIGHT_OUTER_JOIN != MY_SPEC.join_type_

4
src/sql/engine/join/ob_hash_join_op.cpp
View File

@ -1834,7 +1834,7 @@ int ObHashJoinOp::in_memory_process(bool &need_not_read_right)
LOG_WARN("failed to build hash table", K(ret), K(part_level_));
}
if (OB_SUCC(ret)
&& !is_shared_
&& (!is_shared_ || 0 == cur_hash_table_->row_count_)
&& ((0 == num_left_rows
&& RIGHT_ANTI_JOIN != MY_SPEC.join_type_
&& RIGHT_OUTER_JOIN != MY_SPEC.join_type_
@ -3630,7 +3630,7 @@ int ObHashJoinOp::recursive_process(bool &need_not_read_right)
LOG_WARN("failed to build hash table", K(ret), K(part_level_));
}
if (OB_SUCC(ret)
&& !is_shared_
&& (!is_shared_ || 0 == cur_hash_table_->row_count_)
&& ((0 == num_left_rows
&& RIGHT_ANTI_JOIN != MY_SPEC.join_type_
&& RIGHT_OUTER_JOIN != MY_SPEC.join_type_