Skip to content

Commit 357ce48

Browse files
Subham SinghalSubham Singhal
authored andcommitted
Simplify error expr
1 parent 6737e75 commit 357ce48

2 files changed

Lines changed: 26 additions & 25 deletions

File tree

datafusion/spark/src/function/math/negative.rs

Lines changed: 25 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -105,11 +105,9 @@ macro_rules! impl_integer_array_negative {
105105
let result: PrimitiveArray<$type> = if $enable_ansi_mode {
106106
array.try_unary(|x| {
107107
x.checked_neg().ok_or_else(|| {
108-
arrow::error::ArrowError::from(
109-
(exec_err!("{} overflow on negative({x})", $type_name)
110-
as Result<(), _>)
111-
.unwrap_err(),
112-
)
108+
(exec_err!("{} overflow on negative({x})", $type_name)
109+
as Result<(), _>)
110+
.unwrap_err()
113111
})
114112
})?
115113
} else {
@@ -136,11 +134,9 @@ macro_rules! impl_decimal_array_negative {
136134
array
137135
.try_unary(|x| {
138136
x.checked_neg().ok_or_else(|| {
139-
arrow::error::ArrowError::from(
140-
(exec_err!("{} overflow on negative({x})", $type_name)
141-
as Result<(), _>)
142-
.unwrap_err(),
143-
)
137+
(exec_err!("{} overflow on negative({x})", $type_name)
138+
as Result<(), _>)
139+
.unwrap_err()
144140
})
145141
})?
146142
.with_data_type(array.data_type().clone())
@@ -257,20 +253,19 @@ fn spark_negative(
257253
let result: PrimitiveArray<IntervalDayTimeType> = if enable_ansi_mode {
258254
array.try_unary(|x| {
259255
let days = x.days.checked_neg().ok_or_else(|| {
260-
arrow::error::ArrowError::from(
261-
(exec_err!(
262-
"IntervalDayTime overflow on negative (days: {})",
263-
x.days
264-
) as Result<(), _>)
265-
.unwrap_err(),
266-
)
256+
(exec_err!(
257+
"IntervalDayTime overflow on negative (days: {})",
258+
x.days
259+
) as Result<(), _>)
260+
.unwrap_err()
267261
})?;
268262
let milliseconds =
269263
x.milliseconds.checked_neg().ok_or_else(|| {
270-
arrow::error::ArrowError::from((exec_err!(
264+
(exec_err!(
271265
"IntervalDayTime overflow on negative (milliseconds: {})",
272266
x.milliseconds
273-
) as Result<(), _>).unwrap_err())
267+
) as Result<(), _>)
268+
.unwrap_err()
274269
})?;
275270
Ok::<_, arrow::error::ArrowError>(IntervalDayTime {
276271
days,
@@ -291,19 +286,25 @@ fn spark_negative(
291286
{
292287
array.try_unary(|x| {
293288
let months = x.months.checked_neg().ok_or_else(|| {
294-
arrow::error::ArrowError::from((exec_err!(
289+
(exec_err!(
295290
"IntervalMonthDayNano overflow on negative (months: {})",
296291
x.months
297-
) as Result<(), _>).unwrap_err())
292+
) as Result<(), _>)
293+
.unwrap_err()
298294
})?;
299295
let days = x.days.checked_neg().ok_or_else(|| {
300-
arrow::error::ArrowError::from((exec_err!("IntervalMonthDayNano overflow on negative (days: {})", x.days) as Result<(), _>).unwrap_err())
296+
(exec_err!(
297+
"IntervalMonthDayNano overflow on negative (days: {})",
298+
x.days
299+
) as Result<(), _>)
300+
.unwrap_err()
301301
})?;
302302
let nanoseconds = x.nanoseconds.checked_neg().ok_or_else(|| {
303-
arrow::error::ArrowError::from((exec_err!(
303+
(exec_err!(
304304
"IntervalMonthDayNano overflow on negative (nanoseconds: {})",
305305
x.nanoseconds
306-
) as Result<(), _>).unwrap_err())
306+
) as Result<(), _>)
307+
.unwrap_err()
307308
})?;
308309
Ok::<_, arrow::error::ArrowError>(IntervalMonthDayNano {
309310
months,

datafusion/sqllogictest/test_files/spark/math/negative.slt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -320,7 +320,7 @@ SELECT negative((-9223372036854775807)::bigint);
320320
statement ok
321321
CREATE TABLE min_values_ansi AS VALUES (-2147483648);
322322

323-
query error DataFusion error: Arrow error: External error: Execution error: Int32 overflow on negative\(\-2147483648\)
323+
query error DataFusion error: Execution error: Int32 overflow on negative\(\-2147483648\)
324324
SELECT negative(column1::int) FROM min_values_ansi;
325325

326326
statement ok

0 commit comments

Comments
 (0)