This is an automated email from the ASF dual-hosted git repository.
lihaopeng pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new 943cc8aeff2 make mark join column insert false when not null aware
probe is null (#29358)
943cc8aeff2 is described below
commit 943cc8aeff23e3a92f09ab3ef148e6cb602c6ff4
Author: Pxl <[email protected]>
AuthorDate: Tue Jan 2 12:14:31 2024 +0800
make mark join column insert false when not null aware probe is null
(#29358)
---
be/src/vec/exec/join/process_hash_table_probe_impl.h | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git a/be/src/vec/exec/join/process_hash_table_probe_impl.h
b/be/src/vec/exec/join/process_hash_table_probe_impl.h
index 01d4939e057..86719be7783 100644
--- a/be/src/vec/exec/join/process_hash_table_probe_impl.h
+++ b/be/src/vec/exec/join/process_hash_table_probe_impl.h
@@ -294,8 +294,8 @@ Status
ProcessHashTableProbe<JoinOpType>::do_process(HashTableType& hash_table_c
if (is_mark_join) {
++current_offset;
bool null_result =
- (need_null_map_for_probe &&
(*null_map)[probe_index] &&
- !accept_null_value) ||
+ (ignore_null && need_null_map_for_probe &&
+ (*null_map)[probe_index] &&
!accept_null_value) ||
(find_result.is_found() &&
_join_node->_has_null_in_build_side);
if (null_result) {
mark_column->insert_null();
@@ -312,7 +312,8 @@ Status
ProcessHashTableProbe<JoinOpType>::do_process(HashTableType& hash_table_c
if (is_mark_join) {
++current_offset;
bool null_result =
- (need_null_map_for_probe &&
(*null_map)[probe_index]) ||
+ (ignore_null && need_null_map_for_probe &&
+ (*null_map)[probe_index]) ||
(!find_result.is_found() &&
_join_node->_has_null_in_build_side);
if (null_result) {
mark_column->insert_null();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
