|
The reason I ask this is that I try to use UDF in flink scala shell, but I will hit the following error.
The workaround is to add argument ""-Yrepl-class-based" for scala shell. But then I hit another error in
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
|