fmt

Author: comphead

native/core/src/execution/planner.rs

@@ -556,12 +556,12 @@ impl PhysicalPlanner {
                 )))
             }
             ExprStruct::ScalarFunc(expr) => {
-                let func = self.create_scalar_function_expr(expr, input_schema)?;
+                let func = self.create_scalar_function_expr(expr, input_schema);
                 match expr.func.as_ref() {
                     // DataFusion map_extract returns array of struct entries even if lookup by key
                     // Apache Spark waits a single value, so wrap the result into additional list extraction
                     "map_extract" => Ok(Arc::new(ListExtract::new(
-                        func,
+                        func?,
                         Arc::new(Literal::new(ScalarValue::Int32(Some(1)))),
                         None,
                         true,