Update optimize_projections.rs

synnada-ai · May 16, 2024 · 67b1070 · 67b1070
1 parent e4645a5
commit 67b1070
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/datafusion/core/src/physical_optimizer/optimize_projections.rs b/datafusion/core/src/physical_optimizer/optimize_projections.rs
@@ -2092,7 +2092,7 @@ impl ProjectionOptimizer {
             ) {
                 if window_exprs.iter().any(|expr| {
                     expr.clone()
-                        .update_expression(&ExprMapping::new(IndexMap::new()))
+                        .update_expression(&ExprMapping::new(self.schema_mapping.clone()))
                         .is_none()
                 }) {
                     self.children_nodes[0].required_columns = self