You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by bi...@apache.org on 2014/02/25 01:34:46 UTC
git commit: TEZ-885. TestTaskScheduler intermittent failures (bikas)
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 <bi...@apache.org>
Authored: Mon Feb 24 16:34:38 2014 -0800
Committer: Bikas Saha <bi...@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());