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

YARN-1873. Fixed TestDistributedShell failure when the test cases are out of order. Contributed by Mit Desai. 

git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/trunk@1582060 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Zhijie Shen 2014-03-26 21:18:38 +00:00
parent d337a5ffc4
commit 3af3b0bda9
2 changed files with 14 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hadoop-yarn-project/CHANGES.txt
View File

@ -585,6 +585,9 @@ Release 2.4.0 - UNRELEASED
ResourceTrackerProtocol so that they work in HA scenario. (Xuan Gong ResourceTrackerProtocol so that they work in HA scenario. (Xuan Gong
via jianhe) via jianhe)
YARN-1873. Fixed TestDistributedShell failure when the test cases are out of
order. (Mit Desai via zjshen)
Release 2.3.1 - UNRELEASED Release 2.3.1 - UNRELEASED
INCOMPATIBLE CHANGES INCOMPATIBLE CHANGES

21
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

@ -51,8 +51,8 @@
import org.apache.hadoop.yarn.server.nodemanager.containermanager.ContainerManagerImpl; import org.apache.hadoop.yarn.server.nodemanager.containermanager.ContainerManagerImpl;
import org.apache.hadoop.yarn.server.resourcemanager.scheduler.ResourceScheduler; import org.apache.hadoop.yarn.server.resourcemanager.scheduler.ResourceScheduler;
import org.apache.hadoop.yarn.server.resourcemanager.scheduler.fifo.FifoScheduler; import org.apache.hadoop.yarn.server.resourcemanager.scheduler.fifo.FifoScheduler;
import org.junit.AfterClass; import org.junit.After;
import org.junit.BeforeClass; import org.junit.Before;
import org.junit.Test; import org.junit.Test;
public class TestDistributedShell { public class TestDistributedShell {
@ -60,13 +60,14 @@ public class TestDistributedShell {
private static final Log LOG = private static final Log LOG =
LogFactory.getLog(TestDistributedShell.class); LogFactory.getLog(TestDistributedShell.class);
protected static MiniYARNCluster yarnCluster = null; protected MiniYARNCluster yarnCluster = null;
protected static Configuration conf = new YarnConfiguration(); protected Configuration conf = new YarnConfiguration();
protected static String APPMASTER_JAR = JarFinder.getJar(ApplicationMaster.class); protected final static String APPMASTER_JAR =
JarFinder.getJar(ApplicationMaster.class);
@BeforeClass @Before
public static void setup() throws Exception { public void setup() throws Exception {
LOG.info("Starting up YARN cluster"); LOG.info("Starting up YARN cluster");
conf.setInt(YarnConfiguration.RM_SCHEDULER_MINIMUM_ALLOCATION_MB, 128); conf.setInt(YarnConfiguration.RM_SCHEDULER_MINIMUM_ALLOCATION_MB, 128);
conf.setClass(YarnConfiguration.RM_SCHEDULER, conf.setClass(YarnConfiguration.RM_SCHEDULER,
@ -106,11 +107,11 @@ public static void setup() throws Exception {
Thread.sleep(2000); Thread.sleep(2000);
} catch (InterruptedException e) { } catch (InterruptedException e) {
LOG.info("setup thread sleep interrupted. message=" + e.getMessage()); LOG.info("setup thread sleep interrupted. message=" + e.getMessage());
} }
} }
@AfterClass @After
public static void tearDown() throws IOException { public void tearDown() throws IOException {
if (yarnCluster != null) { if (yarnCluster != null) {
try { try {
yarnCluster.stop(); yarnCluster.stop();