We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d5c980f commit 138ff91Copy full SHA for 138ff91
sql/hive/src/main/scala/org/apache/spark/sql/hive/hiveUdfs.scala
@@ -216,7 +216,8 @@ private[spark] object ResolveWindowUdaf extends Rule[LogicalPlan] {
216
val windowFunctionInfo: WindowFunctionInfo =
217
Option(FunctionRegistry.getWindowFunctionInfo(name.toLowerCase)).getOrElse(
218
sys.error(s"Couldn't find udaf function $name"))
219
- HiveGenericUdaf(new HiveFunctionWrapper(windowFunctionInfo.getFunctionClass.getName),
+ HiveGenericUdaf(
220
+ new HiveFunctionWrapper(windowFunctionInfo.getfInfo().getFunctionClass.getName),
221
windowFunctionInfo, children)
222
}
223
0 commit comments