MAPREDUCE-4286. TestClientProtocolProviderImpls passes on failure conditions. Contributed by Devaraj K.
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/7c782047 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/7c782047 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/7c782047 Branch: refs/heads/YARN-2928 Commit: 7c782047c609b29178945bd566a0d162e64dbfdb Parents: 57db50c Author: Tsuyoshi Ozawa <[email protected]> Authored: Wed Feb 18 15:45:52 2015 +0900 Committer: Tsuyoshi Ozawa <[email protected]> Committed: Wed Feb 18 15:45:52 2015 +0900 ---------------------------------------------------------------------- hadoop-mapreduce-project/CHANGES.txt | 3 + .../TestClientProtocolProviderImpls.java | 71 ++++++-------------- 2 files changed, 25 insertions(+), 49 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/7c782047/hadoop-mapreduce-project/CHANGES.txt ---------------------------------------------------------------------- diff --git a/hadoop-mapreduce-project/CHANGES.txt b/hadoop-mapreduce-project/CHANGES.txt index 50e067c..e944d82 100644 --- a/hadoop-mapreduce-project/CHANGES.txt +++ b/hadoop-mapreduce-project/CHANGES.txt @@ -376,6 +376,9 @@ Release 2.7.0 - UNRELEASED MAPREDUCE-6221. Stringifier is left unclosed in Chain#getChainElementConf(). (Ted Yu via ozawa) + MAPREDUCE-4286. TestClientProtocolProviderImpls passes on failure + conditions. (Devaraj K via ozawa) + Release 2.6.1 - UNRELEASED INCOMPATIBLE CHANGES http://git-wip-us.apache.org/repos/asf/hadoop/blob/7c782047/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/mapreduce/TestClientProtocolProviderImpls.java ---------------------------------------------------------------------- diff --git a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/mapreduce/TestClientProtocolProviderImpls.java b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/mapreduce/TestClientProtocolProviderImpls.java index e71c038..6ad76e9 100644 --- a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/mapreduce/TestClientProtocolProviderImpls.java +++ b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/mapreduce/TestClientProtocolProviderImpls.java @@ -18,30 +18,22 @@ package org.apache.hadoop.mapreduce; -import java.io.IOException; +import static org.junit.Assert.assertTrue; +import static org.junit.Assert.fail; -import junit.framework.TestCase; +import java.io.IOException; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.mapred.LocalJobRunner; +import org.apache.hadoop.mapred.YARNRunner; import org.apache.hadoop.mapreduce.server.jobtracker.JTConfig; import org.junit.Test; -public class TestClientProtocolProviderImpls extends TestCase { +public class TestClientProtocolProviderImpls { @Test public void testClusterWithLocalClientProvider() throws Exception { - Configuration conf = new Configuration(); - - try { - conf.set(MRConfig.FRAMEWORK_NAME, "incorrect"); - new Cluster(conf); - fail("Cluster should not be initialized with incorrect framework name"); - } catch (IOException e) { - - } - conf.set(MRConfig.FRAMEWORK_NAME, "local"); Cluster cluster = new Cluster(conf); assertTrue(cluster.getClient() instanceof LocalJobRunner); @@ -50,57 +42,38 @@ public class TestClientProtocolProviderImpls extends TestCase { @Test public void testClusterWithJTClientProvider() throws Exception { - Configuration conf = new Configuration(); try { - conf.set(MRConfig.FRAMEWORK_NAME, "incorrect"); - new Cluster(conf); - fail("Cluster should not be initialized with incorrect framework name"); - - } catch (IOException e) { - - } - - try { conf.set(MRConfig.FRAMEWORK_NAME, "classic"); conf.set(JTConfig.JT_IPC_ADDRESS, "local"); new Cluster(conf); - fail("Cluster with classic Framework name shouldnot use local JT address"); - + fail("Cluster with classic Framework name should not use " + + "local JT address"); } catch (IOException e) { - + assertTrue(e.getMessage().contains( + "Cannot initialize Cluster. Please check")); } + } - try { - conf = new Configuration(); - conf.set(MRConfig.FRAMEWORK_NAME, "classic"); - conf.set(JTConfig.JT_IPC_ADDRESS, "127.0.0.1:0"); - Cluster cluster = new Cluster(conf); - cluster.close(); - } catch (IOException e) { - - } + @Test + public void testClusterWithYarnClientProvider() throws Exception { + Configuration conf = new Configuration(); + conf.set(MRConfig.FRAMEWORK_NAME, "yarn"); + Cluster cluster = new Cluster(conf); + assertTrue(cluster.getClient() instanceof YARNRunner); + cluster.close(); } @Test public void testClusterException() { - Configuration conf = new Configuration(); - conf.set(MRConfig.FRAMEWORK_NAME, MRConfig.CLASSIC_FRAMEWORK_NAME); - conf.set(JTConfig.JT_IPC_ADDRESS, "local"); - - // initializing a cluster with this conf should throw an error. - // However the exception thrown should not be specific to either - // the job tracker client provider or the local provider - boolean errorThrown = false; try { - Cluster cluster = new Cluster(conf); - cluster.close(); - fail("Not expected - cluster init should have failed"); + conf.set(MRConfig.FRAMEWORK_NAME, "incorrect"); + new Cluster(conf); + fail("Cluster should not be initialized with incorrect framework name"); } catch (IOException e) { - errorThrown = true; - assert(e.getMessage().contains("Cannot initialize Cluster. Please check")); + assertTrue(e.getMessage().contains( + "Cannot initialize Cluster. Please check")); } - assert(errorThrown); } }
