[fix-32161] 修复语法检查失败

Author: FlechazoW

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

@@ -26,6 +26,9 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.net.URL;
+import java.net.URLClassLoader;
+
 /**
  *  local模式获取sql任务的执行计划
  * Date: 2020/2/17
@@ -37,17 +40,23 @@ public class GetPlan {
     private static final Logger LOG = LoggerFactory.getLogger(GetPlan.class);
 
     public static String getExecutionPlan(String[] args) {
+        ClassLoader currentClassLoader = Thread.currentThread().getContextClassLoader();
         try {
             long start = System.currentTimeMillis();
             ParamsInfo paramsInfo = ExecuteProcessHelper.parseParams(args);
             paramsInfo.setGetPlan(true);
+            ClassLoader envClassLoader = StreamExecutionEnvironment.class.getClassLoader();
+            ClassLoader plannerClassLoader = URLClassLoader.newInstance(new URL[0], envClassLoader);
+            Thread.currentThread().setContextClassLoader(plannerClassLoader);
             StreamExecutionEnvironment env = ExecuteProcessHelper.getStreamExecution(paramsInfo);
             String executionPlan = env.getExecutionPlan();
             long end = System.currentTimeMillis();
             return ApiResult.createSuccessResultJsonStr(executionPlan, end - start);
         } catch (Exception e) {
             LOG.error("Get plan error", e);
             return ApiResult.createErrorResultJsonStr(ExceptionUtils.getFullStackTrace(e));
+        } finally {
+            Thread.currentThread().setContextClassLoader(currentClassLoader);
         }
     }
 }

core/src/main/java/com/dtstack/flink/sql/exec/ExecuteProcessHelper.java

@@ -249,13 +249,13 @@ public static void registerUserDefinedFunction(SqlTree sqlTree, List<URL> jarUrl
             throws IllegalAccessException, InvocationTargetException {
         // udf和tableEnv须由同一个类加载器加载
         ClassLoader levelClassLoader = tableEnv.getClass().getClassLoader();
+        ClassLoader currentClassLoader = Thread.currentThread().getContextClassLoader();
         URLClassLoader classLoader = null;
         List<CreateFuncParser.SqlParserResult> funcList = sqlTree.getFunctionList();
         for (CreateFuncParser.SqlParserResult funcInfo : funcList) {
             // 构建plan的情况下，udf和tableEnv不需要是同一个类加载器
             if (getPlan) {
-                URL[] urls = jarUrlList.toArray(new URL[0]);
-                classLoader = URLClassLoader.newInstance(urls);
+                classLoader = ClassLoaderManager.loadExtraJar(jarUrlList, (URLClassLoader) currentClassLoader);
             }
 
             //classloader