SAMZA-1389: Fix ZkProcessorLatch await(timeout, TimeUnit) api.
authorShanthoosh Venkataraman <svenkataraman@linkedin.com>
Fri, 11 Aug 2017 18:51:32 +0000 (11:51 -0700)
committerJacob Maes <jmaes@linkedin.com>
Fri, 11 Aug 2017 18:51:32 +0000 (11:51 -0700)
commit46b3601f1a3bbe792338f160f8283ff32b65547a
treeaf6247691181829d483e881c44170a1934cebec2
parent06702af8fda1d016ae55461c404b55b84b20ffd2
SAMZA-1389: Fix ZkProcessorLatch await(timeout, TimeUnit) api.

Use passed in timeUnit value for zkClient.waitUnitExists method rather than hardcoding with  `TimeUnit.MILLISECONDS`.

Author: Shanthoosh Venkataraman <svenkataraman@linkedin.com>

Reviewers: Boris Shkolnik <boryas@apache.org>,Fred Ji <fredji97@yahoo.com>,Jagadish <jvenkatr@linkedin.com>

Closes #268 from shanthoosh/fix_zklatch_impl
samza-core/src/main/java/org/apache/samza/zk/ZkProcessorLatch.java