accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From els...@apache.org
Subject [2/3] git commit: ACCUMULO-3242 Fix bug where transient exceptions didn't sleep before retrying
Date Tue, 21 Oct 2014 16:38:54 GMT
ACCUMULO-3242 Fix bug where transient exceptions didn't sleep before retrying


Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/758a364b
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/758a364b
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/758a364b

Branch: refs/heads/master
Commit: 758a364bda0b47520daf251d88e0057187884d66
Parents: f841082
Author: Josh Elser <elserj@apache.org>
Authored: Tue Oct 21 12:35:20 2014 -0400
Committer: Josh Elser <elserj@apache.org>
Committed: Tue Oct 21 12:35:20 2014 -0400

----------------------------------------------------------------------
 .../main/java/org/apache/accumulo/fate/zookeeper/ZooCache.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/758a364b/fate/src/main/java/org/apache/accumulo/fate/zookeeper/ZooCache.java
----------------------------------------------------------------------
diff --git a/fate/src/main/java/org/apache/accumulo/fate/zookeeper/ZooCache.java b/fate/src/main/java/org/apache/accumulo/fate/zookeeper/ZooCache.java
index d72ac08..d5f7d75 100644
--- a/fate/src/main/java/org/apache/accumulo/fate/zookeeper/ZooCache.java
+++ b/fate/src/main/java/org/apache/accumulo/fate/zookeeper/ZooCache.java
@@ -163,9 +163,9 @@ public class ZooCache {
           log.error("Looked up non-existent node in cache " + e.getPath(), e);
         } else if (code == Code.CONNECTIONLOSS || code == Code.OPERATIONTIMEOUT || code ==
Code.SESSIONEXPIRED) {
           log.warn("Saw (possibly) transient exception communicating with ZooKeeper, will
retry", e);
-          continue;
+        } else {
+          log.warn("Zookeeper error, will retry", e);
         }
-        log.warn("Zookeeper error, will retry", e);
       } catch (InterruptedException e) {
         log.info("Zookeeper error, will retry", e);
       } catch (ConcurrentModificationException e) {


Mime
View raw message