提交 0300aa17 编写于 作者: T twalthr 提交者: StephanEwen

Fixes an issue with wrong ClassLoader when submitting JobJars.

上级 b974e3a1
......@@ -187,6 +187,7 @@ public class Client {
}
public JobExecutionResult run(final PackagedProgram prog, int parallelism, boolean wait) throws ProgramInvocationException {
Thread.currentThread().setContextClassLoader(prog.getUserCodeClassLoader());
if (prog.isUsingProgramEntryPoint()) {
return run(prog.getPlanWithJars(), parallelism, wait);
}
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册