accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From e..@apache.org
Subject [1/3] git commit: ACCUMULO-1821 don't record log events if the tablet is not online
Date Mon, 28 Oct 2013 19:52:57 GMT
Updated Branches:
  refs/heads/1.5.1-SNAPSHOT d61afcc28 -> b77fa14a9


ACCUMULO-1821 don't record log events if the tablet is not online


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

Branch: refs/heads/1.5.1-SNAPSHOT
Commit: 4d493b467ed0c695616bb98878ba929f67ca586e
Parents: 0e88221
Author: Eric Newton <eric.newton@gmail.com>
Authored: Mon Oct 28 15:52:14 2013 -0400
Committer: Eric Newton <eric.newton@gmail.com>
Committed: Mon Oct 28 15:52:28 2013 -0400

----------------------------------------------------------------------
 .../org/apache/accumulo/server/tabletserver/TabletServer.java   | 5 +++++
 1 file changed, 5 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/4d493b46/src/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java
----------------------------------------------------------------------
diff --git a/src/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java
b/src/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java
index dc64714..058973b 100644
--- a/src/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java
+++ b/src/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java
@@ -2559,6 +2559,11 @@ public class TabletServer extends AbstractMetricsImpl implements org.apache.accu
   
   public void addLoggersToMetadata(List<RemoteLogger> logs, KeyExtent extent, int id)
{
     log.info("Adding " + logs.size() + " logs for extent " + extent + " as alias " + id);
+    if (!this.onlineTablets.containsKey(extent)) {
+      // minor compaction due to recovery... don't make updates... if it finishes, there
will be no WALs,
+      // if it doesn't, we'll need to do the same recovery with the old files.
+      return;
+    }
     
     List<MetadataTable.LogEntry> entries = new ArrayList<MetadataTable.LogEntry>();
     long now = RelativeTime.currentTimeMillis();


Mime
View raw message