diff --git a/datafusion/physical-plan/src/joins/hash_join/exec.rs b/datafusion/physical-plan/src/joins/hash_join/exec.rs index 25b320f98550..7f1b8e568039 100644 --- a/datafusion/physical-plan/src/joins/hash_join/exec.rs +++ b/datafusion/physical-plan/src/joins/hash_join/exec.rs @@ -840,7 +840,7 @@ impl HashJoinExec { } fn allow_join_dynamic_filter_pushdown(&self, config: &ConfigOptions) -> bool { - if self.join_type != JoinType::Inner + if !matches!(self.join_type, JoinType::Inner | JoinType::Left) || !config.optimizer.enable_join_dynamic_filter_pushdown { return false;