For review comment.

apache · Feb 25, 2020 · 68d17f7 · 68d17f7
1 parent 83958fb
commit 68d17f7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/Column.scala b/sql/core/src/main/scala/org/apache/spark/sql/Column.scala
@@ -103,7 +103,7 @@ class TypedColumn[-T, U](
    */
   private[sql] def needInputType: Boolean = {
     expr.find {
-      case ta: TypedAggregateExpression if ta.inputDeserializer.isEmpty => true
+      case ta: TypedAggregateExpression => ta.inputDeserializer.isEmpty
       case _ => false
     }.isDefined
   }