x

Author: forsaken628

src/query/service/src/physical_plans/physical_hash_join.rs

@@ -1269,38 +1269,37 @@ impl PhysicalPlanBuilder {
         .await?;
 
         // Step 12: Create and return the HashJoin
+        let build_side_data_distribution = s_expr.build_side_child().get_data_distribution()?;
+        let broadcast_id = if build_side_data_distribution
+            .as_ref()
+            .is_some_and(|e| matches!(e, databend_common_sql::plans::Exchange::NodeToNodeHash(_)))
         {
-            let build_side_data_distribution = s_expr.build_side_child().get_data_distribution()?;
-            let broadcast_id = if build_side_data_distribution.as_ref().is_some_and(|e| {
-                matches!(e, databend_common_sql::plans::Exchange::NodeToNodeHash(_))
-            }) {
-                Some(self.ctx.get_next_broadcast_id())
-            } else {
-                None
-            };
-            Ok(PhysicalPlan::new(HashJoin {
-                projections: projections,
-                build_projections: build_projections,
-                probe_projections: probe_projections,
-                build: build_side,
-                probe: probe_side,
-                join_type: join.join_type,
-                build_keys: right_join_conditions,
-                probe_keys: left_join_conditions,
-                is_null_equal: is_null_equal,
-                non_equi_conditions: non_equi_conditions,
-                marker_index: join.marker_index,
-                meta: PhysicalPlanMeta::new("HashJoin"),
-                from_correlated_subquery: join.from_correlated_subquery,
-                probe_to_build: probe_to_build,
-                output_schema: output_schema,
-                need_hold_hash_table: join.need_hold_hash_table,
-                stat_info: Some(stat_info),
-                single_to_inner: join.single_to_inner,
-                build_side_cache_info: build_side_cache_info,
-                runtime_filter: runtime_filter,
-                broadcast_id,
-            }))
-        }
+            Some(self.ctx.get_next_broadcast_id())
+        } else {
+            None
+        };
+        Ok(PhysicalPlan::new(HashJoin {
+            projections: projections,
+            build_projections: build_projections,
+            probe_projections: probe_projections,
+            build: build_side,
+            probe: probe_side,
+            join_type: join.join_type,
+            build_keys: right_join_conditions,
+            probe_keys: left_join_conditions,
+            is_null_equal: is_null_equal,
+            non_equi_conditions: non_equi_conditions,
+            marker_index: join.marker_index,
+            meta: PhysicalPlanMeta::new("HashJoin"),
+            from_correlated_subquery: join.from_correlated_subquery,
+            probe_to_build: probe_to_build,
+            output_schema: output_schema,
+            need_hold_hash_table: join.need_hold_hash_table,
+            stat_info: Some(stat_info),
+            single_to_inner: join.single_to_inner,
+            build_side_cache_info: build_side_cache_info,
+            runtime_filter: runtime_filter,
+            broadcast_id,
+        }))
     }
 }