SAMZA-1150 : Handling Error propagation between ZkJobCoordinator & DebounceTimer
authorNavina Ramesh <navina@apache.org>
Tue, 9 May 2017 00:58:55 +0000 (17:58 -0700)
committernramesh <nramesh@linkedin.com>
Tue, 9 May 2017 00:58:55 +0000 (17:58 -0700)
commit2d47ee8048d71466b1da695832d009f9dfea0b15
tree0600567574438b8c3520327f5ff72ed240623699
parent28afae09d030d272b63076d0319bda45d3e15f86
SAMZA-1150 : Handling Error propagation between ZkJobCoordinator & DebounceTimer

This PR depends on PR #153
* Treats all errors in jobcoordinator as FATAL and shuts-down the streamprocessor
* [Bug] Fixed bug reported in SAMZA-1241
* Introduced a callback to be associated with the timer (same callback for every Runnable failure)

**TBD**: some more unit tests

Author: Navina Ramesh <navina@apache.org>

Reviewers: Xinyu Liu <xiliu@apache.org>, Prateek Maheshwari <pmaheshw@linkedin.com>

Closes #166 from navina/SAMZA-1150
samza-core/src/main/java/org/apache/samza/zk/ScheduleAfterDebounceTime.java
samza-core/src/main/java/org/apache/samza/zk/ZkJobCoordinator.java
samza-core/src/main/scala/org/apache/samza/system/StreamMetadataCache.scala
samza-core/src/test/java/org/apache/samza/zk/TestScheduleAfterDebounceTime.java