Author: ecn
Date: Wed Jan  9 20:50:29 2013
New Revision: 1431055

URL: http://svn.apache.org/viewvc?rev=1431055&view=rev
Log:
ACCUMULO-919 trash emptier lives in the NN, no need to start our own

Modified:
    
accumulo/trunk/server/src/main/java/org/apache/accumulo/server/gc/SimpleGarbageCollector.java

Modified: 
accumulo/trunk/server/src/main/java/org/apache/accumulo/server/gc/SimpleGarbageCollector.java
URL: 
http://svn.apache.org/viewvc/accumulo/trunk/server/src/main/java/org/apache/accumulo/server/gc/SimpleGarbageCollector.java?rev=1431055&r1=1431054&r2=1431055&view=diff
==============================================================================
--- 
accumulo/trunk/server/src/main/java/org/apache/accumulo/server/gc/SimpleGarbageCollector.java
 (original)
+++ 
accumulo/trunk/server/src/main/java/org/apache/accumulo/server/gc/SimpleGarbageCollector.java
 Wed Jan  9 20:50:29 2013
@@ -65,8 +65,6 @@ import org.apache.accumulo.core.gc.thrif
 import org.apache.accumulo.core.master.state.tables.TableState;
 import org.apache.accumulo.core.security.thrift.AuthInfo;
 import org.apache.accumulo.core.util.CachedConfiguration;
-import org.apache.accumulo.core.util.Daemon;
-import org.apache.accumulo.core.util.LoggingRunnable;
 import org.apache.accumulo.core.util.NamingThreadFactory;
 import org.apache.accumulo.core.util.ServerServices;
 import org.apache.accumulo.core.util.ServerServices.Service;
@@ -197,8 +195,6 @@ public class SimpleGarbageCollector impl
     log.info("delete threads: " + numDeleteThreads);
     if (!noTrash) {
       this.trash = new Trash(fs, fs.getConf());
-      log.info("Starting trash emptier");
-      new Daemon(new LoggingRunnable(log, trash.getEmptier()), "Trash 
Emptier").start();
     }
   }
   


Reply via email to