We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent d37351a commit 600ad76Copy full SHA for 600ad76
1 file changed
datafusion/expr/src/utils.rs
@@ -730,10 +730,13 @@ pub fn from_plan(
730
inputs: &[LogicalPlan],
731
) -> Result<LogicalPlan> {
732
match plan {
733
- LogicalPlan::Projection(_) => Ok(LogicalPlan::Projection(Projection::try_new(
734
- expr.to_vec(),
735
- Arc::new(inputs[0].clone()),
736
- )?)),
+ LogicalPlan::Projection(Projection { schema, .. }) => {
+ Ok(LogicalPlan::Projection(Projection::try_new_with_schema(
+ expr.to_vec(),
+ Arc::new(inputs[0].clone()),
737
+ schema.clone(),
738
+ )?))
739
+ }
740
LogicalPlan::Dml(DmlStatement {
741
table_name,
742
table_schema,
0 commit comments