Details
-
Improvement
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
Description
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.
Attachments
Issue Links
- links to