mark join

zhangstar333 · Dec 27, 2023 · 560d0e7 · 560d0e7
1 parent 3befd30
commit 560d0e7
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -247,7 +247,7 @@ Status ProcessHashTableProbe<JoinOpType>::do_process(HashTableType& hash_table_c
         if (current_offset < _batch_size) {
             while (probe_index < probe_rows) {
                 if constexpr (ignore_null && need_null_map_for_probe) {
-                    if ((*null_map)[probe_index]) {
+                    if (!is_mark_join && (*null_map)[probe_index]) {
                         if constexpr (probe_all) {
                             // only full outer / left outer need insert the data of right table
                             if (LIKELY(current_offset < _build_block_rows.size())) {