This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-1.1-lts
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-1.1-lts by this push:
new a103d1850e [fix](vectorization) Fix right outer join core with
conjunct #14821
a103d1850e is described below
commit a103d1850ee5971469fd5668cf7f93529d28108b
Author: wangbo <[email protected]>
AuthorDate: Tue Dec 6 09:10:51 2022 +0800
[fix](vectorization) Fix right outer join core with conjunct #14821
Co-authored-by: [email protected] <[email protected]>
---
be/src/vec/exec/join/vhash_join_node.cpp | 9 ++++++---
1 file changed, 6 insertions(+), 3 deletions(-)
diff --git a/be/src/vec/exec/join/vhash_join_node.cpp
b/be/src/vec/exec/join/vhash_join_node.cpp
index 171024c950..9cb8cb5ec3 100644
--- a/be/src/vec/exec/join/vhash_join_node.cpp
+++ b/be/src/vec/exec/join/vhash_join_node.cpp
@@ -576,9 +576,12 @@ struct ProcessHashTableProbe {
output_block->get_by_position(result_column_id).column =
std::move(new_filter_column);
} else if constexpr (JoinOpType::value ==
TJoinOp::RIGHT_OUTER_JOIN) {
- for (int i = 0; i < column->size(); ++i) {
- DCHECK(visited_map[i]);
- *visited_map[i] |= column->get_bool(i);
+ if (visited_map.size() != 0) {
+ for (int i = 0; i < column->size(); ++i) {
+ DCHECK(visited_map[i]);
+ bool ret = column->get_bool(i);
+ *visited_map[i] |= ret;
+ }
}
} else if constexpr (JoinOpType::value == TJoinOp::LEFT_SEMI_JOIN)
{
auto new_filter_column = ColumnVector<UInt8>::create();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
