Skip to content

Commit 503c4b8

Browse files
committed
fix
1 parent 7ff42e2 commit 503c4b8

File tree

1 file changed

+3
-5
lines changed
  • native/spark-expr/src/conversion_funcs

1 file changed

+3
-5
lines changed

native/spark-expr/src/conversion_funcs/cast.rs

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1289,11 +1289,7 @@ where
12891289

12901290
match value {
12911291
Some((significand, exponent)) => {
1292-
let mut v = if input_value < 0. {
1293-
-significand
1294-
} else {
1295-
significand
1296-
} as i128;
1292+
let mut v = significand as i128;
12971293

12981294
let k = exponent + scale as i32;
12991295
if k > 0 {
@@ -1303,6 +1299,8 @@ where
13031299
let (div, rem) = if dk < v { v.div_rem(&dk) } else { (0, v) };
13041300
v = if rem * 2 >= dk { div + 1 } else { div };
13051301
}
1302+
v = if input_value < 0. { -v } else { v };
1303+
13061304
if Decimal128Type::validate_decimal_precision(v, precision).is_err() {
13071305
if eval_mode == EvalMode::Ansi {
13081306
return Err(SparkError::NumericValueOutOfRange {

0 commit comments

Comments
 (0)