阅读背景:

Exception in thread "main" java.lang.ClassNotFoundException: com.xxx.flink.udx.TimeFormatUDF_u011250186的博客

来源:互联网 
public static void main(String[] args) throws Exception{

    String classPath = "com.xxx.flink.udx.TimeFormatUDF";

    ClassLoader threadClassLoader = Thread.currentThread().getContextClassLoader();
    DtClassLoader dtClassLoader = new DtClassLoader(new URL[]{}, threadClassLoader);
    List<URL> jarURList = Arrays.asList(new URL("file://C:\Work\liulanqixiazai\pangolin-assembly-0.1-20190919.jar"));
    //FlinkUtil.loadExtraJar(jarURList, dtClassLoader);

    dtClassLoader.addURL(new URL("file://C:\Work\liulanqixiazai\pangolin-assembly-0.1-20190919.jar"));

    // dtClassLoader.getClassLoadingLock(name)
    dtClassLoader.loadClass(classPath);

    ScalarFunction udfFunc = Class.forName(classPath, false, dtClassLoader)
            .asSubclass(ScalarFunction.class).newInstance();
}public static void main(String[] args) throws E



你的当前访问异常,请进行认证后继续阅读剩余内容。

分享到: