fix ScalarUDFImpl.return_type failure

native/Cargo.toml

@@ -22,7 +22,7 @@ resolver = "2"
 [workspace.package]
 version = "0.5.0"
 homepage = "https://datafusion.apache.org/comet"
-repository = "https://github.com/apache/datafusion-comet"
+repository = "https://github.com/andygrove/datafusion-comet"
 authors = ["Apache DataFusion <[email protected]>"]
 description = "Apache DataFusion Comet: High performance accelerator for Apache Spark"
 readme = "README.md"
@@ -39,14 +39,14 @@ arrow-buffer = { version = "53.3.0" }
 arrow-data = { version = "53.3.0" }
 arrow-schema = { version = "53.3.0" }
 parquet = { version = "53.3.0", default-features = false, features = ["experimental"] }
-datafusion-common = { git = "https://github.com/apache/datafusion.git" }
-datafusion = { git = "https://github.com/apache/datafusion.git", default-features = false, features = ["unicode_expressions", "crypto_expressions"] }
-datafusion-functions = { git = "https://github.com/apache/datafusion.git", features = ["crypto_expressions"] }
-datafusion-functions-nested = { git = "https://github.com/apache/datafusion.git", default-features = false }
-datafusion-expr = { git = "https://github.com/apache/datafusion.git", default-features = false }
-datafusion-execution = { git = "https://github.com/apache/datafusion.git", default-features = false }
-datafusion-physical-plan = { git = "https://github.com/apache/datafusion.git", default-features = false }
-datafusion-physical-expr = { git = "https://github.com/apache/datafusion.git", default-features = false }
+datafusion-common = { git = "https://github.com/andygrove/datafusion.git", branch="comet-upgrade" }
+datafusion = { git = "https://github.com/andygrove/datafusion.git", branch="comet-upgrade", default-features = false, features = ["unicode_expressions", "crypto_expressions"] }
+datafusion-functions = { git = "https://github.com/andygrove/datafusion.git", branch="comet-upgrade", features = ["crypto_expressions"] }
+datafusion-functions-nested = { git = "https://github.com/andygrove/datafusion.git", branch="comet-upgrade", default-features = false }
+datafusion-expr = { git = "https://github.com/andygrove/datafusion.git", branch="comet-upgrade", default-features = false }
+datafusion-execution = { git = "https://github.com/andygrove/datafusion.git", branch="comet-upgrade", default-features = false }
+datafusion-physical-plan = { git = "https://github.com/andygrove/datafusion.git", branch="comet-upgrade", default-features = false }
+datafusion-physical-expr = { git = "https://github.com/andygrove/datafusion.git", branch="comet-upgrade", default-features = false }
 datafusion-comet-spark-expr = { path = "spark-expr", version = "0.5.0" }
 datafusion-comet-proto = { path = "proto", version = "0.5.0" }
 chrono = { version = "0.4", default-features = false, features = ["clock"] }

native/core/src/execution/datafusion/planner.rs

@@ -2021,6 +2021,8 @@ impl PhysicalPlanner {
                         .coerce_types(&input_expr_types)
                         .unwrap_or_else(|_| input_expr_types.clone());
 
+                    // TODO need to call `return_type_from_exprs` instead
+                    #[allow(deprecated)]
                     let data_type = func.inner().return_type(&coerced_types)?;
 
                     (data_type, coerced_types)