SAMZA-1368; make sure new job model will be generated in case of barrier timeout.
authorBoris Shkolnik <boryas@apache.org>
Fri, 21 Jul 2017 22:32:58 +0000 (15:32 -0700)
committerJagadish <jagadish@apache.org>
Fri, 21 Jul 2017 22:32:58 +0000 (15:32 -0700)
commit1c1139399599c1cb31249e8d7a28291e2ad9d27e
treef60093319e5777197540cd84c7c2f4d8e354fc93
parent4eb51531387f018ea4350424edc45516ac3aea46
SAMZA-1368; make sure new job model will be generated in case of barrier timeout.

Author: Boris Shkolnik <boryas@apache.org>

Reviewers: Shanthoosh V <svenkata@linkedin.com>

Closes #247 from sborya/onBarrierTimeout1
samza-core/src/main/java/org/apache/samza/zk/ZkJobCoordinator.java