Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

YARN-8535. Fix DistributedShell unit tests. Contributed by Abhishek Modi.

This commit is contained in:
bibinchundatt 2018-09-02 13:35:52 +05:30
parent 6edf3d2ea3
commit eed8415dc1
3 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/main/java/org/apache/hadoop/yarn/applications/distributedshell/ApplicationMaster.java
View File

@ -944,7 +944,7 @@ public class ApplicationMaster {
// When the application completes, it should send a finish application // When the application completes, it should send a finish application
// signal to the RM // signal to the RM
LOG.info("Application completed. Signalling finish to RM"); LOG.info("Application completed. Signalling finished to RM");
FinalApplicationStatus appStatus; FinalApplicationStatus appStatus;
boolean success = true; boolean success = true;

1
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/test/java/org/apache/hadoop/yarn/applications/distributedshell/TestDistributedShell.java
View File

@ -624,6 +624,7 @@ public class TestDistributedShell {
String entityfileName) { String entityfileName) {
String outputDirPathForEntity = String outputDirPathForEntity =
basePath + File.separator + entityType + File.separator; basePath + File.separator + entityType + File.separator;
LOG.info(outputDirPathForEntity);
File outputDirForEntity = new File(outputDirPathForEntity); File outputDirForEntity = new File(outputDirPathForEntity);
Assert.assertTrue(outputDirForEntity.isDirectory()); Assert.assertTrue(outputDirForEntity.isDirectory());

4
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-tests/src/test/java/org/apache/hadoop/yarn/server/MiniYARNCluster.java
View File

@ -577,7 +577,9 @@ public class MiniYARNCluster extends CompositeService {
config.set(YarnConfiguration.NM_LOCALIZER_ADDRESS, config.set(YarnConfiguration.NM_LOCALIZER_ADDRESS,
MiniYARNCluster.getHostname() + ":0"); MiniYARNCluster.getHostname() + ":0");
config.set(YarnConfiguration.NM_COLLECTOR_SERVICE_ADDRESS, config.set(YarnConfiguration.NM_COLLECTOR_SERVICE_ADDRESS,
MiniYARNCluster.getHostname() + ":0"); MiniYARNCluster.getHostname() + ":" +
ServerSocketUtil.getPort(
YarnConfiguration.DEFAULT_NM_COLLECTOR_SERVICE_PORT, 10));
WebAppUtils WebAppUtils
.setNMWebAppHostNameAndPort(config, .setNMWebAppHostNameAndPort(config,
MiniYARNCluster.getHostname(), 0); MiniYARNCluster.getHostname(), 0);