SAMZA-1329: Switch SamzaTaskProxy to use LocalityManager.
authorShanthoosh Venkataraman <svenkataraman@linkedin.com>
Thu, 8 Jun 2017 00:57:54 +0000 (17:57 -0700)
committerJacob Maes <jmaes@linkedin.com>
Thu, 8 Jun 2017 00:57:54 +0000 (17:57 -0700)
commit5418a981d4f9de99aac4e7b3d565373d6dd328df
treefe489ae0e8099b1faf3647ff853368bd0d4f00e6
parent451b2e538611c51c25579e2cab106c241f4eaf52
SAMZA-1329: Switch SamzaTaskProxy to use LocalityManager.

TasksResource(/tasks/) in samza-rest is relying on `JobModelManager.readJobModel` to get jobmodel from (CoordinatorStream, jobConfig). This created binary dependencies of systemstreams defined in task.inputs of job config into samza-rest. Managing those dependencies is hard and unnecessary.

This PR updates `TasksResource` to use `LocalityManager` to read task to container locality.
In the future, this api will read jobmodel from `SamzaMetadatasystem` store.

Author: Shanthoosh Venkataraman <svenkataraman@linkedin.com>

Reviewers: Jacob Maes <jmaes@linkedin.com>

Closes #219 from shanthoosh/fix-2
samza-core/src/main/java/org/apache/samza/coordinator/stream/AbstractCoordinatorStreamManager.java
samza-rest/src/main/java/org/apache/samza/rest/proxy/task/SamzaTaskProxy.java
samza-rest/src/test/java/org/apache/samza/rest/resources/TestTasksResource.java
samza-rest/src/test/java/org/apache/samza/rest/resources/mock/MockInstallationFinder.java
samza-rest/src/test/java/org/apache/samza/rest/resources/mock/MockTaskProxy.java