ACCUMULO-2482 add units to error msg on ZK retries Signed-off-by: Bill Havanki <bhava...@cloudera.com>
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/7461ed92 Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/7461ed92 Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/7461ed92 Branch: refs/heads/1.6.0-SNAPSHOT Commit: 7461ed9245528ee36c6f33122edb450df6da17a4 Parents: c8e165a Author: Alex Moundalexis <al...@clouderagovt.com> Authored: Tue Mar 25 12:53:10 2014 -0400 Committer: Bill Havanki <bhava...@cloudera.com> Committed: Fri Apr 11 13:13:04 2014 -0400 ---------------------------------------------------------------------- .../java/org/apache/accumulo/server/zookeeper/ZooReaderWriter.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo/blob/7461ed92/src/server/src/main/java/org/apache/accumulo/server/zookeeper/ZooReaderWriter.java ---------------------------------------------------------------------- diff --git a/src/server/src/main/java/org/apache/accumulo/server/zookeeper/ZooReaderWriter.java b/src/server/src/main/java/org/apache/accumulo/server/zookeeper/ZooReaderWriter.java index dbaa80b..fa4641f 100644 --- a/src/server/src/main/java/org/apache/accumulo/server/zookeeper/ZooReaderWriter.java +++ b/src/server/src/main/java/org/apache/accumulo/server/zookeeper/ZooReaderWriter.java @@ -175,7 +175,7 @@ public class ZooReaderWriter extends ZooReader implements IZooReaderWriter { return method.invoke(inst, args); } catch (InvocationTargetException e) { if (e.getCause() instanceof KeeperException.ConnectionLossException) { - Logger.getLogger(ZooReaderWriter.class).warn("Error connecting to zookeeper, will retry in " + retryTime, e.getCause()); + Logger.getLogger(ZooReaderWriter.class).warn("Error connecting to zookeeper, will retry in " + String.format("%.2f secs", retryTime / 1000.0), e.getCause()); UtilWaitThread.sleep(retryTime); retryTime = Math.min(5000, retryTime + 250); } else {
