Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5018#discussion_r151153655
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataSetAggFunction.scala
---
@@ -46,7 +46,7 @@ class DataSetAggFunction(
LOG.debug(s"Compiling AggregateHelper: $genAggregations.name \n\n " +
s"Code:\n$genAggregations.code")
val clazz = compile(
- getClass.getClassLoader,
+ getRuntimeContext.getUserCodeClassLoader,
--- End diff --
Should work (if the classloader is correctly set), but I think it's more
explicit to fetch the usercode classloader via the `RuntimeContext`.
---
