[SAMZA-1368] make sure that a new job model will be generated if zk barrier times out.

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.13.1
• Assignee: Boris Shkolnik
• Reporter: Boris Shkolnik
• Created: 20/Jul/17 20:43
• Updated: 22/Jul/17 00:38
• Resolved: 22/Jul/17 00:38

Description

When barrier times out, participants do nothing. We rely on fact that the timeout happened because of a participant leaving. But if it timed out for any other reason, we may end up in a stuck state.
So to cover this unknown we will add an explicit call to doOnProcessorChange for the leader.

Issue Links

• is related to: SAMZA-1064 Standalone Samza with Zookeeper for Coordination
• links to: GitHub Pull Request #247