Yi Pan (Data Infrastructure) created SAMZA-1835:
---------------------------------------------------
Summary: 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)
Fix For: 1.0
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)
