The reason I ask this is that I try to use UDF in flink scala shell, but I
will hit the following error.

[image: image.png]

After some investigation, I found it is a scala issue.
https://issues.scala-lang.org/browse/SI-2034

The workaround is to add argument ""-Yrepl-class-based" for scala shell.
But then I hit another error in
https://github.com/apache/flink/blob/master/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala#L63

After I remove the code above, I can make everything work,  so I just
wonder why UDF can not be non-static inner class ?


-- 
Best Regards

Jeff Zhang

Reply via email to