You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by kt...@apache.org on 2012/01/17 23:32:34 UTC
svn commit: r1232613 -
/incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/Tablet.java
Author: kturner
Date: Tue Jan 17 22:32:34 2012
New Revision: 1232613
URL: http://svn.apache.org/viewvc?rev=1232613&view=rev
Log:
ACCUMULO-314 modified major compactions to immediately requeue tablets if more there are more files to compact after a compaction finishes
Modified:
incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/Tablet.java
Modified: incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/Tablet.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/Tablet.java?rev=1232613&r1=1232612&r2=1232613&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/Tablet.java (original)
+++ incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/Tablet.java Tue Jan 17 22:32:34 2012
@@ -2744,6 +2744,11 @@ public class Tablet {
timer.incrementStatusMajor();
start = System.currentTimeMillis();
majCStats = majorCompact(reason);
+
+ // if there is more work to be done, queue another major compaction
+ if (needsMajorCompaction(reason))
+ initiateMajorCompaction(reason);
+
} catch (RuntimeException E) {
failed = true;
} finally {