diff --git a/src/sql/engine/join/hash_join/ob_hash_join_vec_op.cpp b/src/sql/engine/join/hash_join/ob_hash_join_vec_op.cpp index 48c782ab3..705450683 100644 --- a/src/sql/engine/join/hash_join/ob_hash_join_vec_op.cpp +++ b/src/sql/engine/join/hash_join/ob_hash_join_vec_op.cpp @@ -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_ diff --git a/src/sql/engine/join/ob_hash_join_op.cpp b/src/sql/engine/join/ob_hash_join_op.cpp index 3331d27d6..bf1a980b1 100644 --- a/src/sql/engine/join/ob_hash_join_op.cpp +++ b/src/sql/engine/join/ob_hash_join_op.cpp @@ -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_