fix the bug in 'Last' component

apache · Aug 29, 2014 · 7f6980a · 7f6980a
1 parent b3df91b
commit 7f6980a
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregates.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregates.scala
@@ -511,9 +511,7 @@ case class LastFunction(expr: Expression, base: AggregateExpression) extends Agg
   var result: Any = null
 
   override def update(input: Row): Unit = {
-    if (result == null) {
-      result = input
-    }
+    result = input
   }
 
   override def eval(input: Row): Any = if (result != null) expr.eval(result.asInstanceOf[Row]) else null