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 <[email protected]> Authored: Wed Jul 6 14:23:25 2016 -0700 Committer: Hitesh Shah <[email protected]> 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());
