提交 16cdb612 编写于 作者: M Maximilian Michels

[FLINK-3675][yarn] use classpath paths relative to the application home

This fixes a regression of 0483ba58
where the classpath would start off with the application master's home
dir.
上级 f36aa6ff
......@@ -622,8 +622,6 @@ public abstract class AbstractYarnClusterDescriptor implements ClusterDescriptor
localResources.put(shipFile.getName(), shipResources);
classPathBuilder.append(ApplicationConstants.Environment.PWD.$());
classPathBuilder.append(File.separator);
classPathBuilder.append(shipFile.getName());
if (shipFile.isDirectory()) {
// add directories to the classpath
......@@ -645,11 +643,9 @@ public abstract class AbstractYarnClusterDescriptor implements ClusterDescriptor
localResources.put("flink-conf.yaml", flinkConf);
paths.add(remotePathJar);
classPathBuilder.append(ApplicationConstants.Environment.PWD.$()).append(File.separator)
.append("flink.jar").append(File.pathSeparator);
classPathBuilder.append("flink.jar").append(File.pathSeparator);
paths.add(remotePathConf);
classPathBuilder.append(ApplicationConstants.Environment.PWD.$()).append(File.separator)
.append("flink-conf.yaml").append(File.pathSeparator);
classPathBuilder.append("flink-conf.yaml").append(File.pathSeparator);
sessionFilesDir = new Path(fs.getHomeDirectory(), ".flink/" + appId.toString() + "/");
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册