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