Xinyu Liu created SAMZA-1168:
--------------------------------
Summary: Migrate yarn local runner to use StreamProcessor
Key: SAMZA-1168
URL: https://issues.apache.org/jira/browse/SAMZA-1168
Project: Samza
Issue Type: Bug
Reporter: Xinyu Liu
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.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
