Repository: tez Updated Branches: refs/heads/master d0abd3d54 -> 60645a825
TEZ-3933. Remove sleep from test TestExceptionPropagation (Jonathan Eagles via kshukla) Project: http://git-wip-us.apache.org/repos/asf/tez/repo Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/60645a82 Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/60645a82 Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/60645a82 Branch: refs/heads/master Commit: 60645a8259c1551891ec5f5789e20466bd2fc794 Parents: d0abd3d Author: Kuhu Shukla <[email protected]> Authored: Thu May 10 16:38:16 2018 -0500 Committer: Kuhu Shukla <[email protected]> Committed: Thu May 10 16:38:16 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/60645a82/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) {
