tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kshu...@apache.org
Subject tez git commit: TEZ-3933. Remove sleep from test TestExceptionPropagation (Jonathan Eagles via kshukla)
Date Thu, 10 May 2018 21:45:03 GMT
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 <kshukla@yahoo-inc.com>
Authored: Thu May 10 16:41:26 2018 -0500
Committer: Kuhu Shukla <kshukla@yahoo-inc.com>
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) {


Mime
View raw message