[ 
https://issues.apache.org/jira/browse/SAMZA-1113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15937327#comment-15937327
 ] 

Boris Shkolnik commented on SAMZA-1113:
---------------------------------------

GenerationId sounds like approach in general. Here are couple of open questions:
1. Does user have to generate this id manually, or it could be automated (based 
on the version for example).
2. Since different teams deploy in different way - we may need to have a 
plugable generator for it (yep, one more).
3. If same version restarts will reuse the same structure in ZK, we need to 
introduce a cleanup on START. (we may want to preserve existing/previous 
structure for debugging).

Shutdown:
We need to make sure that orderly shutdown of the JOB doesn't cause 
reshuffling. This may be achieved by creating a flag in ZK.
I prefer this to relying on debounce time.

Do we need to support a case of single processor ONLY shutdown?


> Implement startup and shutdown sequence of jobs in ZK environment
> -----------------------------------------------------------------
>
>                 Key: SAMZA-1113
>                 URL: https://issues.apache.org/jira/browse/SAMZA-1113
>             Project: Samza
>          Issue Type: Sub-task
>            Reporter: Navina Ramesh
>            Assignee: Navina Ramesh
>             Fix For: 0.13.0
>
>         Attachments: SAMZA-1113-0.md, SAMZA-1113-0.pdf
>
>
> Problem that we need to solve is: Do we need multiple job attempts in the ZK 
> tree? If yes, who creates the persistent subtrees? There is no leader until 
> the ZK trees are setup.
> In the initial prototype, the first processor instance creates the ZK 
> hierarchy. If we were to support multiple job attempts, then we need 
> different ZK trees for each attempt. How do all the processors within a job 
> know which the attempt ID to join?



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Reply via email to