Fix

viirya · Jan 23, 2024 · fcf619e · fcf619e
1 parent ac1408a
commit fcf619e
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/datafusion/physical-expr/src/functions.rs b/datafusion/physical-expr/src/functions.rs
@@ -605,10 +605,10 @@ pub fn create_physical_fun(
         }),
         BuiltinScalarFunction::InStr => Arc::new(|args| match args[0].data_type() {
             DataType::Utf8 => {
-                make_scalar_function(string_expressions::instr::<i32>)(args)
+                make_scalar_function_inner(string_expressions::instr::<i32>)(args)
             }
             DataType::LargeUtf8 => {
-                make_scalar_function(string_expressions::instr::<i64>)(args)
+                make_scalar_function_inner(string_expressions::instr::<i64>)(args)
             }
             other => internal_err!("Unsupported data type {other:?} for function instr"),
         }),
@@ -836,10 +836,10 @@ pub fn create_physical_fun(
         }),
         BuiltinScalarFunction::EndsWith => Arc::new(|args| match args[0].data_type() {
             DataType::Utf8 => {
-                make_scalar_function(string_expressions::ends_with::<i32>)(args)
+                make_scalar_function_inner(string_expressions::ends_with::<i32>)(args)
             }
             DataType::LargeUtf8 => {
-                make_scalar_function(string_expressions::ends_with::<i64>)(args)
+                make_scalar_function_inner(string_expressions::ends_with::<i64>)(args)
             }
             other => {
                 internal_err!("Unsupported data type {other:?} for function ends_with")