Skip to content

Commit bd27f58

Browse files
committed
fix
1 parent 7606b5c commit bd27f58

File tree

1 file changed

+3
-3
lines changed
  • sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate

1 file changed

+3
-3
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/Sum.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -95,14 +95,14 @@ case class Sum(child: Expression) extends DeclarativeAggregate with ImplicitCast
9595
}
9696

9797
override lazy val evaluateExpression: Expression = {
98-
val res = resultType match {
98+
val res = sumDataType match {
9999
case d: DecimalType => CheckOverflow(sum, d, SQLConf.get.decimalOperationsNullOnOverflow)
100100
case _ => sum
101101
}
102102
if (sumDataType == resultType) {
103-
sum
103+
res
104104
} else {
105-
Cast(sum, resultType)
105+
Cast(res, resultType)
106106
}
107107
}
108108
}

0 commit comments

Comments
 (0)