|
@@ -182,9 +182,10 @@ public class TestMRApps {
|
|
MRApps.setClasspath(environment, job.getConfiguration());
|
|
MRApps.setClasspath(environment, job.getConfiguration());
|
|
assertTrue(environment.get("CLASSPATH").startsWith(
|
|
assertTrue(environment.get("CLASSPATH").startsWith(
|
|
ApplicationConstants.Environment.PWD.$() + File.pathSeparator));
|
|
ApplicationConstants.Environment.PWD.$() + File.pathSeparator));
|
|
- String yarnAppClasspath =
|
|
|
|
- job.getConfiguration().get(
|
|
|
|
- YarnConfiguration.YARN_APPLICATION_CLASSPATH);
|
|
|
|
|
|
+ String yarnAppClasspath = job.getConfiguration().get(
|
|
|
|
+ YarnConfiguration.YARN_APPLICATION_CLASSPATH,
|
|
|
|
+ StringUtils.join(",",
|
|
|
|
+ YarnConfiguration.DEFAULT_YARN_APPLICATION_CLASSPATH));
|
|
if (yarnAppClasspath != null) {
|
|
if (yarnAppClasspath != null) {
|
|
yarnAppClasspath = yarnAppClasspath.replaceAll(",\\s*", File.pathSeparator)
|
|
yarnAppClasspath = yarnAppClasspath.replaceAll(",\\s*", File.pathSeparator)
|
|
.trim();
|
|
.trim();
|
|
@@ -217,7 +218,10 @@ public class TestMRApps {
|
|
MRApps.setClasspath(environment, conf);
|
|
MRApps.setClasspath(environment, conf);
|
|
assertTrue(environment.get("CLASSPATH").startsWith(
|
|
assertTrue(environment.get("CLASSPATH").startsWith(
|
|
ApplicationConstants.Environment.PWD.$() + File.pathSeparator));
|
|
ApplicationConstants.Environment.PWD.$() + File.pathSeparator));
|
|
- String confClasspath = job.getConfiguration().get(YarnConfiguration.YARN_APPLICATION_CLASSPATH);
|
|
|
|
|
|
+ String confClasspath = job.getConfiguration().get(
|
|
|
|
+ YarnConfiguration.YARN_APPLICATION_CLASSPATH,
|
|
|
|
+ StringUtils.join(",",
|
|
|
|
+ YarnConfiguration.DEFAULT_YARN_APPLICATION_CLASSPATH));
|
|
if (confClasspath != null) {
|
|
if (confClasspath != null) {
|
|
confClasspath = confClasspath.replaceAll(",\\s*", File.pathSeparator)
|
|
confClasspath = confClasspath.replaceAll(",\\s*", File.pathSeparator)
|
|
.trim();
|
|
.trim();
|