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.new...@gmail.com> Authored: Mon Oct 28 15:52:14 2013 -0400 Committer: Eric Newton <eric.new...@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();
