Repository: samza Updated Branches: refs/heads/master 06702af8f -> 46b3601f1
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 <[email protected]> Reviewers: Boris Shkolnik <[email protected]>,Fred Ji <[email protected]>,Jagadish <[email protected]> Closes #268 from shanthoosh/fix_zklatch_impl Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/46b3601f Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/46b3601f Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/46b3601f Branch: refs/heads/master Commit: 46b3601f1a3bbe792338f160f8283ff32b65547a Parents: 06702af Author: Shanthoosh Venkataraman <[email protected]> Authored: Fri Aug 11 11:51:32 2017 -0700 Committer: Jacob Maes <[email protected]> Committed: Fri Aug 11 11:51:32 2017 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/samza/zk/ZkProcessorLatch.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/46b3601f/samza-core/src/main/java/org/apache/samza/zk/ZkProcessorLatch.java ---------------------------------------------------------------------- diff --git a/samza-core/src/main/java/org/apache/samza/zk/ZkProcessorLatch.java b/samza-core/src/main/java/org/apache/samza/zk/ZkProcessorLatch.java index ddc8976..decdd7d 100644 --- a/samza-core/src/main/java/org/apache/samza/zk/ZkProcessorLatch.java +++ b/samza-core/src/main/java/org/apache/samza/zk/ZkProcessorLatch.java @@ -53,8 +53,8 @@ public class ZkProcessorLatch implements Latch { } @Override - public void await(long timeout, TimeUnit tu) { - zkUtils.getZkClient().waitUntilExists(targetPath, TimeUnit.MILLISECONDS, timeout); + public void await(long timeout, TimeUnit timeUnit) { + zkUtils.getZkClient().waitUntilExists(targetPath, timeUnit, timeout); } @Override
