Repository: tez Updated Branches: refs/heads/branch-0.9 5c8ac9516 -> c3c450ad9
TEZ-3933. Remove sleep from test TestExceptionPropagation (Jonathan Eagles via kshukla) (cherry picked from commit 60645a8259c1551891ec5f5789e20466bd2fc794) Project: http://git-wip-us.apache.org/repos/asf/tez/repo Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/c3c450ad Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/c3c450ad Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/c3c450ad Branch: refs/heads/branch-0.9 Commit: c3c450ad9f6ee656097ea76ba5963d3d341e9a0e Parents: 5c8ac95 Author: Kuhu Shukla <[email protected]> Authored: Thu May 10 16:41:26 2018 -0500 Committer: Kuhu Shukla <[email protected]> Committed: Thu May 10 16:41:26 2018 -0500 ---------------------------------------------------------------------- .../test/java/org/apache/tez/test/TestExceptionPropagation.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tez/blob/c3c450ad/tez-tests/src/test/java/org/apache/tez/test/TestExceptionPropagation.java ---------------------------------------------------------------------- diff --git a/tez-tests/src/test/java/org/apache/tez/test/TestExceptionPropagation.java b/tez-tests/src/test/java/org/apache/tez/test/TestExceptionPropagation.java index 404e324..f66bc93 100644 --- a/tez-tests/src/test/java/org/apache/tez/test/TestExceptionPropagation.java +++ b/tez-tests/src/test/java/org/apache/tez/test/TestExceptionPropagation.java @@ -116,7 +116,7 @@ public class TestExceptionPropagation { try { conf.set(MiniDFSCluster.HDFS_MINIDFS_BASEDIR, TEST_ROOT_DIR); dfsCluster = - new MiniDFSCluster.Builder(conf).numDataNodes(3).format(true) + new MiniDFSCluster.Builder(conf).numDataNodes(1).storagesPerDatanode(1).format(true) .racks(null).build(); remoteFs = dfsCluster.getFileSystem(); } catch (IOException io) { @@ -295,7 +295,6 @@ public class TestExceptionPropagation { appReport.getDiagnostics().trim()); } finally { stopNonSessionClient(); - Thread.sleep(10*1000); stopTezMiniCluster(); } } @@ -630,7 +629,6 @@ public class TestExceptionPropagation { output.start(); output.getWriter(); - Thread.sleep(3*1000); if (this.exLocation == ExceptionLocation.PROCESSOR_RUN_ERROR) { throw new Error(this.exLocation.name()); } else if (this.exLocation == ExceptionLocation.PROCESSOR_RUN_EXCEPTION) {
