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

Navina Ramesh updated SAMZA-1128:
---------------------------------
    Affects Version/s: 0.13.0

> Convert ZkBarrierForVersionUpgrade to be more general.
> ------------------------------------------------------
>
>                 Key: SAMZA-1128
>                 URL: https://issues.apache.org/jira/browse/SAMZA-1128
>             Project: Samza
>          Issue Type: Sub-task
>    Affects Versions: 0.13.0
>            Reporter: Boris Shkolnik
>            Assignee: Boris Shkolnik
>            Priority: Blocker
>
> ZkBarrierForVersionUpgrade is tightly coupled with the _ZkJobCoordinator_ 
> implementation. Needs to be refactored.
> Some of the things to clean up :
> * Remove dependency of debounce timer from the _CoordinationUtils_ api
> * Modify schedule api in _ScheduleAfterDebounceTime_ to take an error 
> handling callback (See *TODOs* in the code)



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

Reply via email to