You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by "Jake Maes (JIRA)" <ji...@apache.org> on 2018/01/12 19:27:05 UTC

[jira] [Updated] (SAMZA-1168) Migrate yarn local runner to use StreamProcessor

     [ https://issues.apache.org/jira/browse/SAMZA-1168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jake Maes updated SAMZA-1168:
-----------------------------
    Fix Version/s:     (was: 0.14.0)
                   0.15.0

> 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
>            Assignee: Xinyu Liu
>             Fix For: 0.15.0
>
>
> 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.4.14#64029)