TEZ-2131. Add additional tests for tasks running in the AM. (sseth)
Project: http://git-wip-us.apache.org/repos/asf/tez/repo Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/8b79df52 Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/8b79df52 Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/8b79df52 Branch: refs/heads/TEZ-2003 Commit: 8b79df5286cd79f3e850de00749fd3d949b97962 Parents: 248a994 Author: Siddharth Seth <[email protected]> Authored: Fri Feb 20 17:23:18 2015 -0800 Committer: Siddharth Seth <[email protected]> Committed: Thu Aug 6 01:25:09 2015 -0700 ---------------------------------------------------------------------- TEZ-2003-CHANGES.txt | 1 + .../org/apache/tez/tests/TestExternalTezServices.java | 10 +++++++--- 2 files changed, 8 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tez/blob/8b79df52/TEZ-2003-CHANGES.txt ---------------------------------------------------------------------- diff --git a/TEZ-2003-CHANGES.txt b/TEZ-2003-CHANGES.txt index 76496c9..4b0a12b 100644 --- a/TEZ-2003-CHANGES.txt +++ b/TEZ-2003-CHANGES.txt @@ -6,5 +6,6 @@ ALL CHANGES: TEZ-2122. Setup pluggable components at AM/Vertex level. TEZ-2123. Fix component managers to use pluggable components. (Enable hybrid mode) TEZ-2125. Create a task communicator for local mode. Allow tasks to run in the AM. + TEZ-2131. Add additional tests for tasks running in the AM. INCOMPATIBLE CHANGES: http://git-wip-us.apache.org/repos/asf/tez/blob/8b79df52/tez-ext-service-tests/src/test/java/org/apache/tez/tests/TestExternalTezServices.java ---------------------------------------------------------------------- diff --git a/tez-ext-service-tests/src/test/java/org/apache/tez/tests/TestExternalTezServices.java b/tez-ext-service-tests/src/test/java/org/apache/tez/tests/TestExternalTezServices.java index 01c2080..0ec972b 100644 --- a/tez-ext-service-tests/src/test/java/org/apache/tez/tests/TestExternalTezServices.java +++ b/tez-ext-service-tests/src/test/java/org/apache/tez/tests/TestExternalTezServices.java @@ -40,7 +40,6 @@ import org.apache.tez.service.MiniTezTestServiceCluster; import org.apache.tez.test.MiniTezCluster; import org.junit.AfterClass; import org.junit.BeforeClass; -import org.junit.Ignore; import org.junit.Test; public class TestExternalTezServices { @@ -229,6 +228,13 @@ public class TestExternalTezServices { } @Test(timeout = 60000) + public void testAllInAM() throws Exception { + int expectedExternalSubmissions = 0; // All in AM + runJoinValidate("AllInAM", expectedExternalSubmissions, PROPS_IN_AM, + PROPS_IN_AM, PROPS_IN_AM); + } + + @Test(timeout = 60000) public void testMixed1() throws Exception { // M-ExtService, R-containers int expectedExternalSubmissions = 4 + 0; //4 for 4 src files, 0 for num reducers. runJoinValidate("Mixed1", expectedExternalSubmissions, PROPS_EXT_SERVICE_PUSH, @@ -263,8 +269,6 @@ public class TestExternalTezServices { PROPS_EXT_SERVICE_PUSH, PROPS_IN_AM); } - - @Ignore // Re-activate this after the AM registers the shuffle token with the launcher. @Test(timeout = 60000) public void testMixed6() throws Exception { // M - AM, R - Service int expectedExternalSubmissions = 0 + 3; // 3 for R in service
