File tree Expand file tree Collapse file tree 1 file changed +5
-2
lines changed
core/src/main/java/com/dtstack/flink/sql Expand file tree Collapse file tree 1 file changed +5
-2
lines changed Original file line number Diff line number Diff line change 3030import java .net .URLClassLoader ;
3131
3232/**
33- * local模式获取sql任务的执行计划
33+ * local模式获取sql任务的执行计划
3434 * Date: 2020/2/17
3535 * Company: www.dtstack.com
36+ *
3637 * @author maqi
3738 */
3839public class GetPlan {
@@ -46,7 +47,9 @@ public static String getExecutionPlan(String[] args) {
4647 ParamsInfo paramsInfo = ExecuteProcessHelper .parseParams (args );
4748 paramsInfo .setGetPlan (true );
4849 ClassLoader envClassLoader = StreamExecutionEnvironment .class .getClassLoader ();
49- ClassLoader plannerClassLoader = URLClassLoader .newInstance (new URL [0 ], envClassLoader );
50+ ClassLoader plannerClassLoader = URLClassLoader .newInstance (
51+ paramsInfo .getJarUrlList ().toArray (new URL [0 ]),
52+ envClassLoader );
5053 Thread .currentThread ().setContextClassLoader (plannerClassLoader );
5154 StreamExecutionEnvironment env = ExecuteProcessHelper .getStreamExecution (paramsInfo );
5255 String executionPlan = env .getExecutionPlan ();
You can’t perform that action at this time.
0 commit comments