diff --git a/datafusion/core/src/physical_plan/planner.rs b/datafusion/core/src/physical_plan/planner.rs index a389bb65bdc7e..73ecd5bf753d1 100644 --- a/datafusion/core/src/physical_plan/planner.rs +++ b/datafusion/core/src/physical_plan/planner.rs @@ -1013,7 +1013,10 @@ impl DefaultPhysicalPlanner { LogicalPlan::TableScan(..) => { self.create_initial_plan(input, session_state).await } - _ => Err(DataFusionError::Plan("SubqueryAlias should only wrap TableScan".to_string())) + LogicalPlan::Filter(..) => { + self.create_initial_plan(input, session_state).await + } + _ => Err(DataFusionError::Plan("SubqueryAlias should only wrap TableScan or Filter".to_string())) } } LogicalPlan::Limit(Limit { input, skip, fetch, .. }) => {