Skip to content

Commit 9530ded

Browse files
committed
use internal_err with a faulty value_fields_with_higher_order_udf
1 parent 27fcc8e commit 9530ded

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

‎datafusion/optimizer/src/analyzer/type_coercion.rs‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -781,9 +781,9 @@ impl TreeNodeRewriter for TypeCoercionRewriter<'_> {
781781
let new_args = std::iter::zip(args, new_fields)
782782
.map(|(arg, new_field)| match (&arg, new_field) {
783783
(Expr::Lambda(_lambda), ValueOrLambda::Lambda(_)) => Ok(arg),
784-
(Expr::Lambda(_lambda), ValueOrLambda::Value(_)) => plan_err!("value_fields_with_higher_order_udf return a value for a lambda argument"),
784+
(Expr::Lambda(_lambda), ValueOrLambda::Value(_)) => internal_err!("value_fields_with_higher_order_udf returned a value for a lambda argument"),
785785
(_, ValueOrLambda::Value(new_field)) => arg.cast_to(new_field.data_type(), self.schema),
786-
(_, ValueOrLambda::Lambda(_)) => plan_err!("value_fields_with_higher_order_udf return a lambda for a value argument"),
786+
(_, ValueOrLambda::Lambda(_)) => internal_err!("value_fields_with_higher_order_udf returned a lambda for a value argument"),
787787
})
788788
.collect::<Result<_>>()?;
789789

0 commit comments

Comments
 (0)