Repository: incubator-samza Updated Branches: refs/heads/0.7.0 7fc20974a -> d089d344d
SAMZA-288: Remove kill-AM-over-REST call Project: http://git-wip-us.apache.org/repos/asf/incubator-samza/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-samza/commit/d089d344 Tree: http://git-wip-us.apache.org/repos/asf/incubator-samza/tree/d089d344 Diff: http://git-wip-us.apache.org/repos/asf/incubator-samza/diff/d089d344 Branch: refs/heads/0.7.0 Commit: d089d344dcd0d5931f8bb3c8acd921d9f01357e8 Parents: 7fc2097 Author: Jakob Homan <[email protected]> Authored: Wed Jun 11 12:53:13 2014 -0700 Committer: Jakob Homan <[email protected]> Committed: Wed Jun 11 12:53:13 2014 -0700 ---------------------------------------------------------------------- .../org/apache/samza/webapp/ApplicationMasterRestServlet.scala | 4 ---- 1 file changed, 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/d089d344/samza-yarn/src/main/scala/org/apache/samza/webapp/ApplicationMasterRestServlet.scala ---------------------------------------------------------------------- diff --git a/samza-yarn/src/main/scala/org/apache/samza/webapp/ApplicationMasterRestServlet.scala b/samza-yarn/src/main/scala/org/apache/samza/webapp/ApplicationMasterRestServlet.scala index 8fce8a7..6f02d73 100644 --- a/samza-yarn/src/main/scala/org/apache/samza/webapp/ApplicationMasterRestServlet.scala +++ b/samza-yarn/src/main/scala/org/apache/samza/webapp/ApplicationMasterRestServlet.scala @@ -26,7 +26,6 @@ import org.apache.samza.job.yarn.SamzaAppMasterState import org.apache.samza.job.yarn.ClientHelper import org.apache.samza.metrics._ import scala.collection.JavaConversions._ -import scala.collection.immutable.TreeMap import org.apache.hadoop.yarn.conf.YarnConfiguration import org.codehaus.jackson.map.ObjectMapper import java.util.HashMap @@ -98,7 +97,4 @@ class ApplicationMasterRestServlet(config: Config, state: SamzaAppMasterState, r jsonMapper.writeValueAsString(new HashMap[String, Object](status)) } - get("/am/kill") { - client.kill(state.appAttemptId.getApplicationId) - } }
