Github user gatorsmile commented on a diff in the pull request:
https://github.com/apache/spark/pull/21970#discussion_r207701793
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/CentralMomentAgg.scala
---
@@ -111,23 +111,23 @@ abstract class CentralMomentAgg(child: Expression)
val delta2 = delta * delta
val deltaN2 = deltaN * deltaN
val newM3 = if (momentOrder >= 3) {
- m3 - Literal(3.0) * deltaN * newM2 + delta * (delta2 - deltaN2)
+ m3 - deltaN * 3.0 * newM2 + delta * (delta2 - deltaN2)
--- End diff --
Please avoid these changes
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
