Details
-
Improvement
-
Status: Open
-
Major
-
Resolution: Unresolved
-
1.16.0
-
None
Description
Since FLINK-15635, we have introduced a user classloader in table module to manage all user jars, such as the jar added by `ADD JAR` or `CREATE FUNCTION ... USING JAR` syntax. However, in table API program user can create `StreamExecutionEnvironment` first, then create `TableEnvironment` based on it, the classloader in `StreamExecutionEnvironment` and `TableEnvironment` are not the same. if the user use `ADD JAR` syntax in SQL query, here maybe occur ClassNotFoundException during compile StreamGraph to JobGraph because of the different classloader, so we need to unify the classloader, make sure the classloader is the same.