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/117cb41d Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/117cb41d Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/117cb41d Branch: refs/heads/TEZ-2003 Commit: 117cb41d5905baa2599dc06ef5d0ff89ecc85ef4 Parents: 899a310 Author: Siddharth Seth <[email protected]> Authored: Fri Feb 20 17:23:18 2015 -0800 Committer: Siddharth Seth <[email protected]> Committed: Fri Aug 14 13:46:42 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/117cb41d/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/117cb41d/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
