Skip to content

Commit

Permalink
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
fix
Browse files Browse the repository at this point in the history
BiteTheDDDDt committed Dec 20, 2024

Verified

This commit was signed with the committer’s verified signature.
gforcada Gil Forcada Codinachs
1 parent 30b7650 commit 5e74d10
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions be/src/pipeline/exec/join/process_hash_table_probe_impl.h
Original file line number Diff line number Diff line change
@@ -372,7 +372,6 @@ Status ProcessHashTableProbe<JoinOpType>::do_mark_join_conjuncts(vectorized::Blo
JoinOpType == TJoinOp::NULL_AWARE_LEFT_ANTI_JOIN;
constexpr bool is_null_aware_join = JoinOpType == TJoinOp::NULL_AWARE_LEFT_SEMI_JOIN ||
JoinOpType == TJoinOp::NULL_AWARE_LEFT_ANTI_JOIN;
DCHECK_EQ(_parent->_mark_join_conjuncts.empty(), is_null_aware_join);
const auto row_count = output_block->rows();
if (!row_count) {
return Status::OK();
@@ -472,7 +471,7 @@ Status ProcessHashTableProbe<JoinOpType>::do_mark_join_conjuncts(vectorized::Blo
mark_filter_data[i] = false;
}
} else {
if (mark_null_map[i]) { // is null
if (mark_null_map[i]) {
_parent->_last_probe_null_mark = _probe_indexs[i];
} else if (mark_filter_data[i] && not_matched_before) {
_parent->_last_probe_match = _probe_indexs[i];

0 comments on commit 5e74d10

Please sign in to comment.