You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by ec...@apache.org on 2015/10/23 21:21:56 UTC
accumulo git commit: ACCUMULO-4038 assume a missing WAL node means
the server had no logs
Repository: accumulo
Updated Branches:
refs/heads/master 93e7a04bd -> feff4f9ac
ACCUMULO-4038 assume a missing WAL node means the server had no logs
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/feff4f9a
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/feff4f9a
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/feff4f9a
Branch: refs/heads/master
Commit: feff4f9aca7334ac0b01771f29a4696f9ff97a11
Parents: 93e7a04
Author: Eric C. Newton <er...@gmail.com>
Authored: Fri Oct 23 15:21:41 2015 -0400
Committer: Eric C. Newton <er...@gmail.com>
Committed: Fri Oct 23 15:21:41 2015 -0400
----------------------------------------------------------------------
.../main/java/org/apache/accumulo/server/log/WalStateManager.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/accumulo/blob/feff4f9a/server/base/src/main/java/org/apache/accumulo/server/log/WalStateManager.java
----------------------------------------------------------------------
diff --git a/server/base/src/main/java/org/apache/accumulo/server/log/WalStateManager.java b/server/base/src/main/java/org/apache/accumulo/server/log/WalStateManager.java
index 52844c1..1516176 100644
--- a/server/base/src/main/java/org/apache/accumulo/server/log/WalStateManager.java
+++ b/server/base/src/main/java/org/apache/accumulo/server/log/WalStateManager.java
@@ -146,6 +146,8 @@ public class WalStateManager {
result.add(parts.getSecond());
}
}
+ } catch (KeeperException.NodeExistsException e) {
+ log.debug("{} has no wal entry in zookeeper, assuming no logs", tsi);
} catch (KeeperException | InterruptedException e) {
throw new WalMarkerException(e);
}