Fix the safemode delay timeunit.
Project: http://git-wip-us.apache.org/repos/asf/incubator-blur/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-blur/commit/ddc013f8 Tree: http://git-wip-us.apache.org/repos/asf/incubator-blur/tree/ddc013f8 Diff: http://git-wip-us.apache.org/repos/asf/incubator-blur/diff/ddc013f8 Branch: refs/heads/0.1.5 Commit: ddc013f84308543dc90e41fa44c9a98c2b36bd7c Parents: 5ce5947 Author: Aaron McCurry <[email protected]> Authored: Tue Apr 30 20:55:13 2013 -0400 Committer: Aaron McCurry <[email protected]> Committed: Tue Apr 30 20:55:13 2013 -0400 ---------------------------------------------------------------------- .../indexserver/DistributedIndexServer.java | 2 +- 1 files changed, 1 insertions(+), 1 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/ddc013f8/src/blur-core/src/main/java/org/apache/blur/manager/indexserver/DistributedIndexServer.java ---------------------------------------------------------------------- diff --git a/src/blur-core/src/main/java/org/apache/blur/manager/indexserver/DistributedIndexServer.java b/src/blur-core/src/main/java/org/apache/blur/manager/indexserver/DistributedIndexServer.java index c35af15..351bbdf 100644 --- a/src/blur-core/src/main/java/org/apache/blur/manager/indexserver/DistributedIndexServer.java +++ b/src/blur-core/src/main/java/org/apache/blur/manager/indexserver/DistributedIndexServer.java @@ -169,7 +169,7 @@ public class DistributedIndexServer extends AbstractIndexServer { registerMyselfAsMemberOfCluster(); String onlineShardsPath = ZookeeperPathConstants.getOnlineShardsPath(_cluster); String safemodePath = ZookeeperPathConstants.getSafemodePath(_cluster); - SafeMode safeMode = new SafeMode(_zookeeper, safemodePath, onlineShardsPath, TimeUnit.SECONDS, _safeModeDelay, TimeUnit.SECONDS, 60); + SafeMode safeMode = new SafeMode(_zookeeper, safemodePath, onlineShardsPath, TimeUnit.MILLISECONDS, _safeModeDelay, TimeUnit.SECONDS, 60); safeMode.registerNode(getNodeName(), BlurUtil.getVersion().getBytes()); _running.set(true);
