diff --git a/datafusion/physical-expr/src/unicode_expressions.rs b/datafusion/physical-expr/src/unicode_expressions.rs index 29328d72ce17..f27b3c157741 100644 --- a/datafusion/physical-expr/src/unicode_expressions.rs +++ b/datafusion/physical-expr/src/unicode_expressions.rs @@ -463,10 +463,10 @@ pub fn translate(args: &[ArrayRef]) -> Result { /// SUBSTRING_INDEX('www.apache.org', '.', -1) = org pub fn substr_index(args: &[ArrayRef]) -> Result { if args.len() != 3 { - return Err(DataFusionError::Internal(format!( - "substr_index function requires three arguments, got {}", + return internal_err!( + "substr_index was called with {} arguments. It requires 3.", args.len() - ))); + ); } let string_array = as_generic_string_array::(&args[0])?;