SAMZA-1389: Fix ZkProcessorLatch await(timeout, TimeUnit) api.
[samza.git] / samza-core / src / main / java / org / apache / samza / zk / ZkProcessorLatch.java
index ddc8976..decdd7d 100644 (file)
@@ -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