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 2013/09/12 21:39:35 UTC
[2/5] git commit: ACCUMULO-1542 only clean up temp files if there is
some evidence that the previous tablet server failed
ACCUMULO-1542 only clean up temp files if there is some evidence that the previous tablet server failed
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/3a414da6
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/3a414da6
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/3a414da6
Branch: refs/heads/master
Commit: 3a414da6a68c097bc5d77db1bd1e53294fdece6f
Parents: a238494
Author: Eric Newton <er...@gmail.com>
Authored: Thu Sep 12 15:31:15 2013 -0400
Committer: Eric Newton <er...@gmail.com>
Committed: Thu Sep 12 15:31:15 2013 -0400
----------------------------------------------------------------------
.../java/org/apache/accumulo/server/tabletserver/Tablet.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/accumulo/blob/3a414da6/src/server/src/main/java/org/apache/accumulo/server/tabletserver/Tablet.java
----------------------------------------------------------------------
diff --git a/src/server/src/main/java/org/apache/accumulo/server/tabletserver/Tablet.java b/src/server/src/main/java/org/apache/accumulo/server/tabletserver/Tablet.java
index f3c756a..9c26568 100644
--- a/src/server/src/main/java/org/apache/accumulo/server/tabletserver/Tablet.java
+++ b/src/server/src/main/java/org/apache/accumulo/server/tabletserver/Tablet.java
@@ -1481,7 +1481,11 @@ public class Tablet {
+ " entries created)");
}
- removeOldTemporaryFiles();
+ // look for hints of a failure on the previous tablet server
+ if (!logEntries.isEmpty() || needsMajorCompaction(MajorCompactionReason.NORMAL)) {
+ // look for any temp files hanging around
+ removeOldTemporaryFiles();
+ }
// do this last after tablet is completely setup because it
// could cause major compaction to start