[jira] [Assigned] (SAMZA-816) LocalityManager.register() should not register coordinator stream SystemConsumer in SamzaContainer context

["Yi Pan (Data Infrastructure) (JIRA)" <ji...@apache.org>]

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

Yi Pan (Data Infrastructure) reassigned SAMZA-816:
--------------------------------------------------

    Assignee: Yi Pan (Data Infrastructure)

> LocalityManager.register() should not register coordinator stream SystemConsumer in SamzaContainer context
> ----------------------------------------------------------------------------------------------------------
>
>                 Key: SAMZA-816
>                 URL: https://issues.apache.org/jira/browse/SAMZA-816
>             Project: Samza
>          Issue Type: Bug
>    Affects Versions: 0.10.0
>            Reporter: Yi Pan (Data Infrastructure)
>            Assignee: Yi Pan (Data Infrastructure)
>             Fix For: 0.10.0
>
>
> In current code, LocalityManager.register() is invoked under SamzaContainer context as well, which results in a false positive in the metrics messages_behind_high_watermark: it include the lag the container has on the coordinator stream as well, while there is no logic in the container to consume the coordinator stream. It would be better to make two versions of LocalityManager, one is used by JobCoordinator that reads the locality data, while the other is used by SamzaContainer to write the locality data.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)