Index: src/java/org/apache/hadoop/hbase/HRegionServer.java =================================================================== --- src/java/org/apache/hadoop/hbase/HRegionServer.java (revision 648446) +++ src/java/org/apache/hadoop/hbase/HRegionServer.java (working copy) @@ -22,7 +22,6 @@ import java.io.IOException; import java.lang.Thread.UncaughtExceptionHandler; import java.lang.reflect.Constructor; -import java.lang.reflect.Member; import java.net.InetSocketAddress; import java.net.UnknownHostException; import java.util.ArrayList; @@ -50,7 +49,6 @@ import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; -import org.apache.hadoop.dfs.AlreadyBeingCreatedException; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; import org.apache.hadoop.hbase.filter.RowFilterInterface; @@ -254,8 +252,10 @@ if (e == null) { continue; } - e.getRegion().compactIfNeeded(); - split(e.getRegion()); + synchronized (compactSplitLock) { // Don't interrupt us while working + e.getRegion().compactIfNeeded(); + split(e.getRegion()); + } } catch (InterruptedException ex) { continue; } catch (IOException ex) {