You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by na...@apache.org on 2015/09/30 02:48:20 UTC
samza git commit: SAMZA-779 : Remove the dependency on JUnit from
SamzaTaskManager
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 <ja...@gmail.com>
Authored: Tue Sep 29 17:46:31 2015 -0700
Committer: Navina <na...@gmail.com>
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