From 76ca57cf2154b3ea5d0364aad89821a5c2af8012 Mon Sep 17 00:00:00 2001
From: zhangstar333 <87313068+zhangstar333@users.noreply.github.com>
Date: Fri, 8 Sep 2023 17:55:03 +0800
Subject: [PATCH] [bug](join) fix outer join not add tuple is null column when
 build rows is 0 (#23974)

fix outer join not add tuple is null column when build rows is 0
---
 be/src/vec/exec/join/vhash_join_node.cpp | 37 ++++++++++++++----------
 be/src/vec/exec/join/vhash_join_node.h   |  3 ++
 2 files changed, 24 insertions(+), 16 deletions(-)

diff --git a/be/src/vec/exec/join/vhash_join_node.cpp b/be/src/vec/exec/join/vhash_join_node.cpp
index 40258339044b5b..a7190e0323c5b0 100644
--- a/be/src/vec/exec/join/vhash_join_node.cpp
+++ b/be/src/vec/exec/join/vhash_join_node.cpp
@@ -483,17 +483,17 @@ Status HashJoinNode::pull(doris::RuntimeState* state, vectorized::Block* output_
             temp_block.insert({std::move(nullable_column), make_nullable(type),
                                _right_table_column_names[i]});
         }
-
-        {
-            SCOPED_TIMER(_join_filter_timer);
-            RETURN_IF_ERROR(
-                    VExprContext::filter_block(_conjuncts, &temp_block, temp_block.columns()));
+        if (_is_outer_join) {
+            reinterpret_cast<ColumnUInt8*>(_tuple_is_null_left_flag_column.get())
+                    ->get_data()
+                    .resize_fill(block_rows, 0);
+            reinterpret_cast<ColumnUInt8*>(_tuple_is_null_right_flag_column.get())
+                    ->get_data()
+                    .resize_fill(block_rows, 1);
         }
-
-        RETURN_IF_ERROR(_build_output_block(&temp_block, output_block, false));
+        RETURN_IF_ERROR(_filter_data_and_build_output(state, output_block, eos, &temp_block));
         temp_block.clear();
         release_block_memory(_probe_block);
-        reached_limit(output_block, eos);
         return Status::OK();
     }
     _join_block.clear_column_data();
@@ -570,22 +570,27 @@ Status HashJoinNode::pull(doris::RuntimeState* state, vectorized::Block* output_
     if (!st) {
         return st;
     }
+    RETURN_IF_ERROR(_filter_data_and_build_output(state, output_block, eos, &temp_block));
+    // Here make _join_block release the columns' ptr
+    _join_block.set_columns(_join_block.clone_empty_columns());
+    mutable_join_block.clear();
+    return Status::OK();
+}
 
+Status HashJoinNode::_filter_data_and_build_output(RuntimeState* state,
+                                                   vectorized::Block* output_block, bool* eos,
+                                                   Block* temp_block) {
     if (_is_outer_join) {
-        _add_tuple_is_null_column(&temp_block);
+        _add_tuple_is_null_column(temp_block);
     }
-    auto output_rows = temp_block.rows();
+    auto output_rows = temp_block->rows();
     DCHECK(output_rows <= state->batch_size());
     {
         SCOPED_TIMER(_join_filter_timer);
-        RETURN_IF_ERROR(VExprContext::filter_block(_conjuncts, &temp_block, temp_block.columns()));
+        RETURN_IF_ERROR(VExprContext::filter_block(_conjuncts, temp_block, temp_block->columns()));
     }
 
-    // Here make _join_block release the columns' ptr
-    _join_block.set_columns(_join_block.clone_empty_columns());
-    mutable_join_block.clear();
-    RETURN_IF_ERROR(_build_output_block(&temp_block, output_block, false));
-
+    RETURN_IF_ERROR(_build_output_block(temp_block, output_block, false));
     _reset_tuple_is_null_column();
     reached_limit(output_block, eos);
     return Status::OK();
diff --git a/be/src/vec/exec/join/vhash_join_node.h b/be/src/vec/exec/join/vhash_join_node.h
index fe5139d4670ffa..c57d11392b584f 100644
--- a/be/src/vec/exec/join/vhash_join_node.h
+++ b/be/src/vec/exec/join/vhash_join_node.h
@@ -702,6 +702,9 @@ class HashJoinNode final : public VJoinNodeBase {
     // add tuple is null flag column to Block for filter conjunct and output expr
     void _add_tuple_is_null_column(Block* block) override;
 
+    Status _filter_data_and_build_output(RuntimeState* state, vectorized::Block* output_block,
+                                         bool* eos, Block* temp_block);
+
     template <class HashTableContext>
     friend struct ProcessHashTableBuild;