tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ss...@apache.org
Subject git commit: TEZ-405. Fix intermittent test failures in TestContainerReuse. (sseth)
Date Wed, 28 Aug 2013 21:12:42 GMT
Updated Branches:
  refs/heads/master 507c2dc67 -> 21e5a60f7


TEZ-405. Fix intermittent test failures in TestContainerReuse. (sseth)


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

Branch: refs/heads/master
Commit: 21e5a60f7410fc6204312065f46fc57948c58d58
Parents: 507c2dc
Author: Siddharth Seth <sseth@apache.org>
Authored: Wed Aug 28 14:12:10 2013 -0700
Committer: Siddharth Seth <sseth@apache.org>
Committed: Wed Aug 28 14:12:10 2013 -0700

----------------------------------------------------------------------
 .../test/java/org/apache/tez/dag/app/rm/TestContainerReuse.java   | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/21e5a60f/tez-dag/src/test/java/org/apache/tez/dag/app/rm/TestContainerReuse.java
----------------------------------------------------------------------
diff --git a/tez-dag/src/test/java/org/apache/tez/dag/app/rm/TestContainerReuse.java b/tez-dag/src/test/java/org/apache/tez/dag/app/rm/TestContainerReuse.java
index 057c59d..e232ec0 100644
--- a/tez-dag/src/test/java/org/apache/tez/dag/app/rm/TestContainerReuse.java
+++ b/tez-dag/src/test/java/org/apache/tez/dag/app/rm/TestContainerReuse.java
@@ -335,6 +335,7 @@ public class TestContainerReuse {
 
     // One container allocated.
     taskScheduler.onContainersAllocated(Collections.singletonList(container1));
+    drainableAppCallback.drain();
     verify(taskSchedulerEventHandler).taskAllocated(eq(ta11), any(Object.class), eq(container1));
 
     // Task assigned to container completed successfully. Container should be re-used.
@@ -451,6 +452,7 @@ public class TestContainerReuse {
 
     // One container allocated.
     taskScheduler.onContainersAllocated(Collections.singletonList(container1));
+    drainableAppCallback.drain();
     verify(taskSchedulerEventHandler).taskAllocated(eq(ta11), any(Object.class), eq(container1));
 
     // Send launch request for task2 (vertex2)
@@ -542,6 +544,7 @@ public class TestContainerReuse {
 
     // One container allocated.
     taskScheduler.onContainersAllocated(Collections.singletonList(container1));
+    drainableAppCallback.drain();
     verify(taskSchedulerEventHandler).taskAllocated(eq(ta11), any(Object.class), eq(container1));
 
     // Send launch request for task2 (vertex2)


Mime
View raw message