[fix](join)the build and probe expr should be calculated before converting input block to nullable

Author: starocean999

be/src/vec/columns/column_const.h

@@ -185,7 +185,7 @@ class ColumnConst final : public COWHelper<IColumn, ColumnConst> {
         return false;
     }
 
-    //    bool is_nullable() const override { return is_column_nullable(*data); }
+    bool is_nullable() const override { return data->is_nullable(); }
     bool only_null() const override { return data->is_null_at(0); }
     bool is_numeric() const override { return data->is_numeric(); }
     bool is_fixed_and_contiguous() const override { return data->is_fixed_and_contiguous(); }

be/src/vec/exec/join/vhash_join_node.cpp

@@ -997,10 +997,6 @@ Status HashJoinNode::get_next(RuntimeState* state, Block* output_block, bool* eo
         probe_rows = _probe_block.rows();
         if (probe_rows != 0) {
             COUNTER_UPDATE(_probe_rows_counter, probe_rows);
-            if (_join_op == TJoinOp::RIGHT_OUTER_JOIN || _join_op == TJoinOp::FULL_OUTER_JOIN) {
-                _probe_column_convert_to_null = _convert_block_to_null(_probe_block);
-            }
-
             int probe_expr_ctxs_sz = _probe_expr_ctxs.size();
             _probe_columns.resize(probe_expr_ctxs_sz);
             if (_null_map_column == nullptr) {
@@ -1024,6 +1020,9 @@ Status HashJoinNode::get_next(RuntimeState* state, Block* output_block, bool* eo
                     _hash_table_variants);
 
             RETURN_IF_ERROR(st);
+            if (_join_op == TJoinOp::RIGHT_OUTER_JOIN || _join_op == TJoinOp::FULL_OUTER_JOIN) {
+                _probe_column_convert_to_null = _convert_block_to_null(_probe_block);
+            }
         }
     }
 
@@ -1323,9 +1322,6 @@ Status HashJoinNode::_extract_probe_join_column(Block& block, NullMap& null_map,
 
 Status HashJoinNode::_process_build_block(RuntimeState* state, Block& block, uint8_t offset) {
     SCOPED_TIMER(_build_table_timer);
-    if (_join_op == TJoinOp::LEFT_OUTER_JOIN || _join_op == TJoinOp::FULL_OUTER_JOIN) {
-        _convert_block_to_null(block);
-    }
     size_t rows = block.rows();
     if (UNLIKELY(rows == 0)) {
         return Status::OK();
@@ -1372,6 +1368,9 @@ Status HashJoinNode::_process_build_block(RuntimeState* state, Block& block, uin
             },
             _hash_table_variants);
 
+    if (_join_op == TJoinOp::LEFT_OUTER_JOIN || _join_op == TJoinOp::FULL_OUTER_JOIN) {
+        _convert_block_to_null(block);
+    }
     return st;
 }
 

regression-test/data/correctness_p0/test_outer_join_with_subquery.out

@@ -0,0 +1,4 @@
+-- This file is automatically generated. You should know what you did if you want to edit this
+-- !select --
+1
+

regression-test/suites/correctness_p0/test_outer_join_with_subquery.groovy

@@ -0,0 +1,88 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements.  See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership.  The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License.  You may obtain a copy of the License at
+//
+//   http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied.  See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+suite("test_outer_join_with_subquery") {
+    sql """
+        drop table if exists test_outer_join_with_subquery_outerjoin_A;
+    """
+
+    sql """
+        drop table if exists test_outer_join_with_subquery_outerjoin_B;
+    """
+    
+    sql """
+        create table test_outer_join_with_subquery_outerjoin_A ( a int not null )
+        ENGINE=OLAP
+        DISTRIBUTED BY HASH(a) BUCKETS 1
+        PROPERTIES (
+        "replication_allocation" = "tag.location.default: 1",
+        "in_memory" = "false",
+        "storage_format" = "V2"
+        );
+    """
+
+    sql """
+        create table test_outer_join_with_subquery_outerjoin_B ( a int not null )
+        ENGINE=OLAP
+        DISTRIBUTED BY HASH(a) BUCKETS 1
+        PROPERTIES (
+        "replication_allocation" = "tag.location.default: 1",
+        "in_memory" = "false",
+        "storage_format" = "V2"
+        );
+    """
+
+    sql """
+        insert into test_outer_join_with_subquery_outerjoin_A values( 1 );
+    """
+
+    sql """
+        insert into test_outer_join_with_subquery_outerjoin_B values( 1 );
+    """
+
+    qt_select """
+        select
+        subq_1.c1
+        from
+        (
+            select
+            case
+                when test_outer_join_with_subquery_outerjoin_A.a is NULL then test_outer_join_with_subquery_outerjoin_A.a
+                else test_outer_join_with_subquery_outerjoin_A.a
+            end as c1
+            from
+            test_outer_join_with_subquery_outerjoin_A
+        ) as subq_1
+        full join (
+            select
+            case
+                when test_outer_join_with_subquery_outerjoin_B.a is NULL then test_outer_join_with_subquery_outerjoin_B.a
+                else test_outer_join_with_subquery_outerjoin_B.a
+            end as c2
+            from
+            test_outer_join_with_subquery_outerjoin_B
+        ) as subq_2 on (subq_1.c1 = subq_2.c2);
+    """
+
+    sql """
+        drop table if exists test_outer_join_with_subquery_outerjoin_A;
+    """
+
+    sql """
+        drop table if exists test_outer_join_with_subquery_outerjoin_B;
+    """
+}