tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bi...@apache.org
Subject git commit: TEZ-1065 addendum-1 to fix broken test (bikas)
Date Fri, 15 Aug 2014 21:50:45 GMT
Repository: tez
Updated Branches:
  refs/heads/master 5d78968ef -> 5212b926c


TEZ-1065 addendum-1 to fix broken test (bikas)


Project: http://git-wip-us.apache.org/repos/asf/tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/5212b926
Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/5212b926
Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/5212b926

Branch: refs/heads/master
Commit: 5212b926c2bfd16d0f63d89814e9710a97bc4362
Parents: 5d78968
Author: Bikas Saha <bikas@apache.org>
Authored: Fri Aug 15 14:49:19 2014 -0700
Committer: Bikas Saha <bikas@apache.org>
Committed: Fri Aug 15 14:49:43 2014 -0700

----------------------------------------------------------------------
 .../src/test/java/org/apache/tez/test/TestTezJobs.java  | 12 +++++++++---
 1 file changed, 9 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/tez/blob/5212b926/tez-tests/src/test/java/org/apache/tez/test/TestTezJobs.java
----------------------------------------------------------------------
diff --git a/tez-tests/src/test/java/org/apache/tez/test/TestTezJobs.java b/tez-tests/src/test/java/org/apache/tez/test/TestTezJobs.java
index f3393f1..a8028ea 100644
--- a/tez-tests/src/test/java/org/apache/tez/test/TestTezJobs.java
+++ b/tez-tests/src/test/java/org/apache/tez/test/TestTezJobs.java
@@ -386,11 +386,12 @@ public class TestTezJobs {
   @Test (timeout=60000)
   public void testVertexOrder() throws Exception {
     TezConfiguration tezConf = new TezConfiguration(mrrTezCluster.getConfig());
-    TezClient tezSession = new TezClient("TestVertexOrder", tezConf, true);
-    tezSession.start();
+    TezClient tezClient = new TezClient("TestVertexOrder", tezConf);
+    tezClient.start();
 
+    try {
     DAG dag = SimpleTestDAG.createDAGForVertexOrder("dag1", conf);
-    DAGClient dagClient = tezSession.submitDAG(dag);
+    DAGClient dagClient = tezClient.submitDAG(dag);
     DAGStatus dagStatus = dagClient.getDAGStatus(null);
     while (!dagStatus.isCompleted()) {
       LOG.info("Waiting for dag to complete. Sleeping for 500ms."
@@ -419,5 +420,10 @@ public class TestTezJobs {
       }
       i++;
     }
+    } finally {
+      if (tezClient != null) {
+        tezClient.stop();
+      }
+    }
   }
 }


Mime
View raw message