Repository: incubator-samza Updated Branches: refs/heads/master b3b485cce -> 80bf78204
SAMZA-231: Remove dead code from SamzaAppMasterTaskManager::startContainer() Project: http://git-wip-us.apache.org/repos/asf/incubator-samza/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-samza/commit/73fea8d6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-samza/tree/73fea8d6 Diff: http://git-wip-us.apache.org/repos/asf/incubator-samza/diff/73fea8d6 Branch: refs/heads/master Commit: 73fea8d630ff8bc2c16ddac2f3a4acf4a61fdb54 Parents: b3b485c Author: Yan Fang <yanfang724 at gmail dot com> Authored: Tue Apr 8 22:41:45 2014 -0700 Committer: Jakob Homan <[email protected]> Committed: Tue Apr 8 22:41:45 2014 -0700 ---------------------------------------------------------------------- .../org/apache/samza/job/yarn/SamzaAppMasterTaskManager.scala | 3 --- 1 file changed, 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/73fea8d6/samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterTaskManager.scala ---------------------------------------------------------------------- diff --git a/samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterTaskManager.scala b/samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterTaskManager.scala index 418a981..58b2d30 100644 --- a/samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterTaskManager.scala +++ b/samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterTaskManager.scala @@ -265,9 +265,6 @@ class SamzaAppMasterTaskManager(clock: () => Long, config: Config, state: SamzaA protected def startContainer(packagePath: Path, container: Container, env: Map[String, String], cmds: String*) { info("starting container %s %s %s %s" format (packagePath, container, env, cmds)) - // connect to container manager (based on similar code in the ContainerLauncher in Hadoop MapReduce) - val contToken = container.getContainerToken - val address = container.getNodeId.getHost + ":" + container.getNodeId.getPort // set the local package so that the containers and app master are provisioned with it val packageResource = Records.newRecord(classOf[LocalResource])
