Repository: samza Updated Branches: refs/heads/master 2ba6e3480 -> eb80cfee8
SAMZA-779 : Remove the dependency on JUnit from SamzaTaskManager Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/eb80cfee Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/eb80cfee Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/eb80cfee Branch: refs/heads/master Commit: eb80cfee885d10d8d875dc42afdb2868a5fffbb3 Parents: 2ba6e34 Author: Jake Maes <[email protected]> Authored: Tue Sep 29 17:46:31 2015 -0700 Committer: Navina <[email protected]> Committed: Tue Sep 29 17:47:49 2015 -0700 ---------------------------------------------------------------------- .../main/java/org/apache/samza/job/yarn/SamzaTaskManager.java | 4 ---- 1 file changed, 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/eb80cfee/samza-yarn/src/main/java/org/apache/samza/job/yarn/SamzaTaskManager.java ---------------------------------------------------------------------- diff --git a/samza-yarn/src/main/java/org/apache/samza/job/yarn/SamzaTaskManager.java b/samza-yarn/src/main/java/org/apache/samza/job/yarn/SamzaTaskManager.java index c2a9ac0..12f2f2c 100644 --- a/samza-yarn/src/main/java/org/apache/samza/job/yarn/SamzaTaskManager.java +++ b/samza-yarn/src/main/java/org/apache/samza/job/yarn/SamzaTaskManager.java @@ -36,8 +36,6 @@ import org.slf4j.LoggerFactory; import java.util.HashMap; import java.util.Map; -import static junit.framework.Assert.assertTrue; - /** * Samza's application master is mostly interested in requesting containers to * run Samza jobs. SamzaTaskManager is responsible for requesting new @@ -113,8 +111,6 @@ class SamzaTaskManager implements YarnAppMasterListener { // Request initial set of containers Map<Integer, String> containerToHostMapping = state.jobCoordinator.jobModel().getAllContainerLocality(); - assertTrue(containerToHostMapping.size() == state.containerCount); - containerAllocator.requestContainers(containerToHostMapping); // Start container allocator thread
