diff --git a/native/spark-expr/src/abs.rs b/native/spark-expr/src/abs.rs index 4ccc9495f..fa25a7775 100644 --- a/native/spark-expr/src/abs.rs +++ b/native/spark-expr/src/abs.rs @@ -77,11 +77,10 @@ impl ScalarUDFImpl for Abs { if self.eval_mode == EvalMode::Legacy { Ok(args[0].clone()) } else { - Err(DataFusionError::External(Box::new( - SparkError::ArithmeticOverflow { - from_type: self.data_type_name.clone(), - }, - ))) + Err(SparkError::ArithmeticOverflow { + from_type: self.data_type_name.clone(), + } + .into()) } } other => other,