fix.

apache · Aug 13, 2017 · 12cefc2 · 12cefc2
1 parent a65607c
commit 12cefc2
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/SessionCatalog.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/SessionCatalog.scala
@@ -1115,7 +1115,6 @@ class SessionCatalog(
           Utils.classForName("org.apache.spark.sql.expressions.UserDefinedAggregateFunction")
         if (clsForUDAF.isAssignableFrom(clazz)) {
           val cls = Utils.classForName("org.apache.spark.sql.execution.aggregate.ScalaUDAF")
-          // val ctor = classOf[Integer].getConstructor(classOf[Int])
           cls.getConstructor(classOf[Seq[Expression]], clsForUDAF, classOf[Int], classOf[Int])
             .newInstance(children, clazz.newInstance().asInstanceOf[Object], Int.box(1), Int.box(1))
             .asInstanceOf[Expression]