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.

Browse Source 
(cherry picked from commit eed8415dc18fa7415ebd105350bd0532b3b1b6bb)
This commit is contained in:
bibinchundatt 2018-09-02 13:35:52 +05:30
parent d06717ef94
commit 5514f02a73
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

@ -824,7 +824,7 @@ protected boolean finish() {
// When the application completes, it should send a finish application
// signal to the RM
LOG.info("Application completed. Signalling finish to RM");
LOG.info("Application completed. Signalling finished to RM");
FinalApplicationStatus appStatus;
String appMessage = null;

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

@ -615,6 +615,7 @@ private File verifyEntityTypeFileExists(String basePath, String entityType,
String entityfileName) {
String outputDirPathForEntity =
basePath + File.separator + entityType + File.separator;
LOG.info(outputDirPathForEntity);
File outputDirForEntity = new File(outputDirPathForEntity);
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

@ -576,7 +576,9 @@ protected synchronized void serviceInit(Configuration conf)
config.set(YarnConfiguration.NM_LOCALIZER_ADDRESS,
MiniYARNCluster.getHostname() + ":0");
config.set(YarnConfiguration.NM_COLLECTOR_SERVICE_ADDRESS,
MiniYARNCluster.getHostname() + ":0");
MiniYARNCluster.getHostname() + ":" +
ServerSocketUtil.getPort(
YarnConfiguration.DEFAULT_NM_COLLECTOR_SERVICE_PORT, 10));
WebAppUtils
.setNMWebAppHostNameAndPort(config,
MiniYARNCluster.getHostname(), 0);