[flinksql][udf类不能加载][19234]

Author: simenliuxing

core/src/main/java/com/dtstack/flink/sql/Main.java

@@ -249,12 +249,14 @@ private static void registerUDF(SqlTree sqlTree, List<URL> jarURList, URLClassLo
                                     StreamTableEnvironment tableEnv)
             throws ClassNotFoundException, NoSuchMethodException, IllegalAccessException, InvocationTargetException {
         //register urf
+        // udf函数只能由appclassloader加载
+        ClassLoader superClassLoader = Thread.currentThread().getContextClassLoader().getParent();
         URLClassLoader classLoader = null;
         List<CreateFuncParser.SqlParserResult> funcList = sqlTree.getFunctionList();
         for (CreateFuncParser.SqlParserResult funcInfo : funcList) {
             //classloader
             if (classLoader == null) {
-                classLoader = FlinkUtil.loadExtraJar(jarURList, parentClassloader);
+                classLoader = FlinkUtil.loadExtraJar(jarURList, (URLClassLoader)superClassLoader);
             }
             FlinkUtil.registerUDF(funcInfo.getType(), funcInfo.getClassName(), funcInfo.getName(),
                     tableEnv, classLoader);