From f69d73c0f5c130d78f0b3bcf0967185466fd9c50 Mon Sep 17 00:00:00 2001 From: "Anthony Zh. Oon" Date: Thu, 26 Sep 2024 01:12:06 +1000 Subject: [PATCH] Add reference to meet &JoinType type required --- datafusion/core/src/physical_optimizer/enforce_distribution.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/datafusion/core/src/physical_optimizer/enforce_distribution.rs b/datafusion/core/src/physical_optimizer/enforce_distribution.rs index c971e6150633..72df7b15bd27 100644 --- a/datafusion/core/src/physical_optimizer/enforce_distribution.rs +++ b/datafusion/core/src/physical_optimizer/enforce_distribution.rs @@ -298,7 +298,7 @@ fn adjust_input_keys_ordering( right.clone(), new_conditions.0, filter.clone(), - join_type, + &join_type, // TODO: although projection is not used in the join here, because projection pushdown is after enforce_distribution. Maybe we need to handle it later. Same as filter. projection.clone(), PartitionMode::Partitioned,