Details
-
Bug
-
Status: Open
-
Major
-
Resolution: Unresolved
-
None
-
None
-
None
Description
Right now LocalContainerRunner is used in Yarn to run SamzaContainers on each node. This is not consistent with the real local runner which uses StreamProcessor to run locally. We should be able to wrap the simple coordination (get jobModel) inside a JobCoordinator and make this a StreamProcessor.
Attachments
Issue Links
- is a child of
-
SAMZA-1789 Refactor the application runtime classes so that we have a unified pattern to write and launch applications in high- and low-level APIs in YARN and standalone
- Resolved