You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by jg...@apache.org on 2014/06/18 20:09:19 UTC

git commit: SAMZA-287: Expose config via AM REST interface

Repository: incubator-samza
Updated Branches:
  refs/heads/master edcecedc1 -> 64da867b2


SAMZA-287: Expose config via AM REST interface


Project: http://git-wip-us.apache.org/repos/asf/incubator-samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-samza/commit/64da867b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-samza/tree/64da867b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-samza/diff/64da867b

Branch: refs/heads/master
Commit: 64da867b27ef810a0cc7cc55b13934e6b6708c95
Parents: edceced
Author: David Chen <dc...@linkedin.com>
Authored: Wed Jun 18 11:09:04 2014 -0700
Committer: Jakob Homan <jg...@apache.org>
Committed: Wed Jun 18 11:09:04 2014 -0700

----------------------------------------------------------------------
 .../org/apache/samza/webapp/ApplicationMasterRestServlet.scala    | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/64da867b/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 32f7b2f..520f784 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
@@ -99,4 +99,7 @@ class ApplicationMasterRestServlet(config: Config, state: SamzaAppMasterState, r
     jsonMapper.writeValueAsString(new HashMap[String, Object](status))
   }
 
+  get("/config") {
+    jsonMapper.writeValueAsString(new HashMap[String, Object](config.toMap))
+  }
 }