Thanks Alexander for reporting this issue, Could you open a jira ticket as well?
CC: Shengkai, please take a look this ticket, looks like an incompatibility change. Best, Leonard > 2022年11月4日 下午6:15，Alexander Fedulov <a...@deltastream.io> 写道： > > Hi everyone, > > 1.16 introduced quite a lot of changes with respect to classloading in the > Table API. The way UDFs could previously be loaded from JARs in 1.15 does not > work in 1.16 anymore - it fails with the ClassNotFound exception when UDFs > are used at runtime. > > Here is a repository with a reproducible example: > https://github.com/afedulov/udfs-flink-1.16/blob/main/src/test/java/com/example/UDFTest.java > > <https://github.com/afedulov/udfs-flink-1.16/blob/main/src/test/java/com/example/UDFTest.java> > > It works as is (Flink 1.15.2) and fails when switching the dependencies to > 1.16.0. > > Here are some of the PRs that, I believe, might be related to the issue: > https://github.com/apache/flink/pull/20001 > <https://github.com/apache/flink/pull/20001> > https://github.com/apache/flink/pull/19845 > <https://github.com/apache/flink/pull/19845> > https://github.com/apache/flink/pull/20211 > <https://github.com/apache/flink/pull/20211> (fixes a similar issue > introduced after classloading changes in 1.16) > > How can UDF JARs be loaded in 1.16? > > Best, > Alexander Fedulov
