From 8699765618da32f164331a646e98a2d0267a9290 Mon Sep 17 00:00:00 2001 From: Richard Lee Date: Mon, 21 Sep 2015 18:28:20 -0700 Subject: [PATCH] Add REST endpoint under /ws/v1/samza at tracking url --- .../scala/org/apache/samza/job/yarn/SamzaAppMasterService.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterService.scala b/samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterService.scala index 060538623e..82d2deb568 100644 --- a/samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterService.scala +++ b/samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterService.scala @@ -50,6 +50,7 @@ class SamzaAppMasterService(config: Config, state: SamzaAppMasterState, registry webApp = new HttpServer(resourceBasePath = "scalate") webApp.addServlet("/*", new ApplicationMasterWebServlet(config, state)) + webApp.addServlet("/ws/v1/samza/*", new ApplicationMasterRestServlet(config, state, registry)) webApp.start state.jobCoordinator.start