tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bi...@apache.org
Subject git commit: TEZ-885. TestTaskScheduler intermittent failures (bikas)
Date Tue, 25 Feb 2014 00:34:46 GMT
Repository: incubator-tez
Updated Branches:
  refs/heads/master f41e3ee02 -> b38c9313e


TEZ-885. TestTaskScheduler intermittent failures (bikas)


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

Branch: refs/heads/master
Commit: b38c9313ec4bf1436d5aa749922b28e80b262894
Parents: f41e3ee
Author: Bikas Saha <bikas@apache.org>
Authored: Mon Feb 24 16:34:38 2014 -0800
Committer: Bikas Saha <bikas@apache.org>
Committed: Mon Feb 24 16:34:38 2014 -0800

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


http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/b38c9313/tez-dag/src/test/java/org/apache/tez/dag/app/rm/TestTaskScheduler.java
----------------------------------------------------------------------
diff --git a/tez-dag/src/test/java/org/apache/tez/dag/app/rm/TestTaskScheduler.java b/tez-dag/src/test/java/org/apache/tez/dag/app/rm/TestTaskScheduler.java
index 4d93eb1..150ef7a 100644
--- a/tez-dag/src/test/java/org/apache/tez/dag/app/rm/TestTaskScheduler.java
+++ b/tez-dag/src/test/java/org/apache/tez/dag/app/rm/TestTaskScheduler.java
@@ -709,10 +709,12 @@ public class TestTaskScheduler {
 
     // deallocate allocated task
     assertTrue(scheduler.deallocateTask(mockTask1, true));
+    drainableAppCallback.drain();
     verify(mockApp).containerBeingReleased(mockCId1);
     verify(mockRMClient).releaseAssignedContainer(mockCId1);
     // deallocate allocated container
     Assert.assertEquals(mockTask2, scheduler.deallocateContainer(mockCId2));
+    drainableAppCallback.drain();
     verify(mockRMClient).releaseAssignedContainer(mockCId2);
     verify(mockRMClient, times(3)).releaseAssignedContainer((ContainerId) any());
 


Mime
View raw message