You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by hi...@apache.org on 2016/07/06 21:24:14 UTC

tez git commit: TEZ-3325. Flaky test in TestDAGImpl.testCounterLimits. (Zhiyuan Yang via hitesh)

Repository: tez
Updated Branches:
  refs/heads/master befc426cb -> 5e61d65fd


TEZ-3325. Flaky test in TestDAGImpl.testCounterLimits. (Zhiyuan Yang via hitesh)


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

Branch: refs/heads/master
Commit: 5e61d65fda48b562b4f2f5460b7a7348feb26725
Parents: befc426
Author: Hitesh Shah <hi...@apache.org>
Authored: Wed Jul 6 14:23:25 2016 -0700
Committer: Hitesh Shah <hi...@apache.org>
Committed: Wed Jul 6 14:23:25 2016 -0700

----------------------------------------------------------------------
 CHANGES.txt                                                      | 1 +
 .../test/java/org/apache/tez/dag/app/dag/impl/TestDAGImpl.java   | 4 ++--
 2 files changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/tez/blob/5e61d65f/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index 4e3f3fb..13d66bb 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -7,6 +7,7 @@ INCOMPATIBLE CHANGES
 
 ALL CHANGES:
 
+  TEZ-3325. Flaky test in TestDAGImpl.testCounterLimits.
   TEZ-3323. Update licese and notice for xml-apis jar. Also update year in notice to 2016.
   TEZ-3223. Support a NullHistoryLogger to disable history logging if needed.
   TEZ-3313. ATSFileParser : Wrong args passed in VersionInfo.

http://git-wip-us.apache.org/repos/asf/tez/blob/5e61d65f/tez-dag/src/test/java/org/apache/tez/dag/app/dag/impl/TestDAGImpl.java
----------------------------------------------------------------------
diff --git a/tez-dag/src/test/java/org/apache/tez/dag/app/dag/impl/TestDAGImpl.java b/tez-dag/src/test/java/org/apache/tez/dag/app/dag/impl/TestDAGImpl.java
index 4471278..b7fe551 100644
--- a/tez-dag/src/test/java/org/apache/tez/dag/app/dag/impl/TestDAGImpl.java
+++ b/tez-dag/src/test/java/org/apache/tez/dag/app/dag/impl/TestDAGImpl.java
@@ -2277,13 +2277,13 @@ public class TestDAGImpl {
     dispatcher.await();
     for (int i=0; i<3; ++i) {
       Vertex v = mrrDag.getVertex("vertex"+(i+1));
-      dispatcher.getEventHandler().handle(new VertexEventTaskCompleted(
-          TezTaskID.getInstance(v.getVertexId(), 0), TaskState.SUCCEEDED));
       TezCounters ctrs = new TezCounters();
       for (int j = 0; j < 50; ++j) {
         ctrs.findCounter("g", "c" + i + "_" + j).increment(1);
       }
       ((VertexImpl) v).setCounters(ctrs);
+      dispatcher.getEventHandler().handle(new VertexEventTaskCompleted(
+        TezTaskID.getInstance(v.getVertexId(), 0), TaskState.SUCCEEDED));
       dispatcher.await();
       Assert.assertEquals(VertexState.SUCCEEDED, v.getState());
       Assert.assertEquals(i+1, mrrDag.getSuccessfulVertices());