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 2019/02/26 00:52:03 UTC

[jira] [Updated] (SAMZA-1835) Consolidate all processorId generation code to StreamProcessor

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

Jake Maes updated SAMZA-1835:
-----------------------------
    Fix Version/s:     (was: 1.1)
                   1.0.1
                   1.0.1

> Consolidate all processorId generation code to StreamProcessor
> --------------------------------------------------------------
>
>                 Key: SAMZA-1835
>                 URL: https://issues.apache.org/jira/browse/SAMZA-1835
>             Project: Samza
>          Issue Type: Improvement
>            Reporter: Yi Pan (Data Infrastructure)
>            Assignee: Shanthoosh Venkataraman
>            Priority: Major
>             Fix For: 1.0.1
>
>
> Currently, the processorId creation function createProcessorId() is repeated in three different implementation of JobCoordinator: ZkJobCoordinator, PassthroughJobCoordinator, and AzureJobCoordinator.
> Making the processId generation dependent on JobCoordinator is also not required now and each processor should know the durable processorId at the startup time, not depending on the creation of JobCoordinator. Hence, consolidating the createProcessorId() code to StreamProcessor and pass the processId to the JobCoordinator constructor should be the right thing to do.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)