From 12cefc24ebd73c5f986bea50d0d30ca7ff791ae2 Mon Sep 17 00:00:00 2001 From: gatorsmile Date: Sat, 12 Aug 2017 18:02:11 -0700 Subject: [PATCH] fix. --- .../org/apache/spark/sql/catalyst/catalog/SessionCatalog.scala | 1 - 1 file changed, 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 index 03694b04bdbea..58df686f97496 100644 --- 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]