From 5e74d10dee1a5afa01a1479c26f014d0168a91f4 Mon Sep 17 00:00:00 2001 From: BiteTheDDDDt Date: Fri, 20 Dec 2024 21:48:03 +0800 Subject: [PATCH] fix --- be/src/pipeline/exec/join/process_hash_table_probe_impl.h | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/be/src/pipeline/exec/join/process_hash_table_probe_impl.h b/be/src/pipeline/exec/join/process_hash_table_probe_impl.h index 58c1967ac6d0e2a..232fad32b1d5fae 100644 --- a/be/src/pipeline/exec/join/process_hash_table_probe_impl.h +++ b/be/src/pipeline/exec/join/process_hash_table_probe_impl.h @@ -372,7 +372,6 @@ Status ProcessHashTableProbe::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::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];