HBASE-3920 HLog hbase.regionserver.flushlogentries no longer supported

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1127377 13f79535-47bb-0310-9956-ffa450edef68

CHANGES.txt

@@ -292,6 +292,8 @@ Release 0.90.4 - Unreleased
   IMPROVEMENT
    HBASE-3882  hbase-config.sh needs to be updated so it can auto-detects the
                sun jre provided by RHEL6 (Roman Shaposhnik)
+   HBASE-3920  HLog hbase.regionserver.flushlogentries no longer supported
+               (Dave Latham)
 
 Release 0.90.3 - May 19th, 2011
 

src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLog.java

@@ -125,7 +125,6 @@ public class HLog implements Syncable {
     new CopyOnWriteArrayList<WALObserver>();
   private final long optionalFlushInterval;
   private final long blocksize;
-  private final int flushlogentries;
   private final String prefix;
   private final Path oldLogDir;
   private boolean logRollRequested;
@@ -336,8 +335,6 @@ public class HLog implements Syncable {
         registerWALActionsListener(i);
       }
     }
-    this.flushlogentries =
-      conf.getInt("hbase.regionserver.flushlogentries", 1);
     this.blocksize = conf.getLong("hbase.regionserver.hlog.blocksize",
       this.fs.getDefaultBlockSize());
     // Roll at 95% of block size.
@@ -363,7 +360,6 @@ public class HLog implements Syncable {
       StringUtils.byteDesc(this.blocksize) +
       ", rollsize=" + StringUtils.byteDesc(this.logrollsize) +
       ", enabled=" + this.enabled +
-      ", flushlogentries=" + this.flushlogentries +
       ", optionallogflushinternal=" + this.optionalFlushInterval + "ms");
     // If prefix is null||empty then just name it hlog
     this.prefix = prefix == null || prefix.isEmpty() ?
@@ -945,8 +941,6 @@ public class HLog implements Syncable {
 
     private final long optionalFlushInterval;
 
-    private boolean syncerShuttingDown = false;
-
     LogSyncer(long optionalFlushInterval) {
       this.optionalFlushInterval = optionalFlushInterval;
     }
@@ -967,12 +961,12 @@ public class HLog implements Syncable {
       } catch (InterruptedException e) {
         LOG.debug(getName() + " interrupted while waiting for sync requests");
       } finally {
-        syncerShuttingDown = true;
         LOG.info(getName() + " exiting");
       }
     }
   }
 
+  @Override
   public void sync() throws IOException {
     synchronized (this.updateLock) {
       if (this.closed) {

src/main/resources/hbase-default.xml

@@ -176,13 +176,6 @@
     in milliseconds.
     </description>
   </property>
-  <property>
-    <name>hbase.regionserver.flushlogentries</name>
-    <value>1</value>
-    <description>Sync the HLog to HDFS when it has accumulated this many
-    entries. Default 1. Value is checked on every HLog.hflush
-    </description>
-  </property>
   <property>
     <name>hbase.regionserver.optionallogflushinterval</name>
     <value>1000</value>

src/test/java/org/apache/hadoop/hbase/TestFullLogReconstruction.java

@@ -48,7 +48,6 @@ public class TestFullLogReconstruction {
   @BeforeClass
   public static void setUpBeforeClass() throws Exception {
     Configuration c = TEST_UTIL.getConfiguration();
-    c.setInt("hbase.regionserver.flushlogentries", 1);
     c.setBoolean("dfs.support.append", true);
     // quicker heartbeat interval for faster DN death notification
     c.setInt("heartbeat.recheck.interval", 5000);
@@ -57,7 +56,6 @@ public class TestFullLogReconstruction {
     // faster failover with cluster.shutdown();fs.close() idiom
     c.setInt("ipc.client.connect.max.retries", 1);
     c.setInt("dfs.client.block.recovery.retries", 1);
-    c.setInt("hbase.regionserver.flushlogentries", 1);
     TEST_UTIL.startMiniCluster(2);
   }
 

src/test/java/org/apache/hadoop/hbase/coprocessor/TestWALObserver.java

@@ -97,7 +97,6 @@ public class TestWALObserver {
         SampleRegionWALObserver.class.getName());
     conf.setBoolean("dfs.support.append", true);
     conf.setInt("dfs.client.block.recovery.retries", 2);
-    conf.setInt("hbase.regionserver.flushlogentries", 1);
 
     TEST_UTIL.startMiniCluster(1);
     TEST_UTIL.setNameNodeNameSystemLeasePeriod(100, 10000);

src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestHLog.java

@@ -98,8 +98,6 @@ public class TestHLog  {
   public static void setUpBeforeClass() throws Exception {
     // Make block sizes small.
     TEST_UTIL.getConfiguration().setInt("dfs.blocksize", 1024 * 1024);
-    TEST_UTIL.getConfiguration().setInt(
-        "hbase.regionserver.flushlogentries", 1);
     // needed for testAppendClose()
     TEST_UTIL.getConfiguration().setBoolean("dfs.support.append", true);
     // quicker heartbeat interval for faster DN death notification

src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestHLogSplit.java

@@ -108,8 +108,6 @@ public class TestHLogSplit {
 
   @BeforeClass
   public static void setUpBeforeClass() throws Exception {
-    TEST_UTIL.getConfiguration().
-            setInt("hbase.regionserver.flushlogentries", 1);
     TEST_UTIL.getConfiguration().
             setBoolean("dfs.support.append", true);
     TEST_UTIL.getConfiguration().

src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestWALReplay.java

@@ -77,7 +77,6 @@ public class TestWALReplay {
     conf.setBoolean("dfs.support.append", true);
     // The below config supported by 0.20-append and CDH3b2
     conf.setInt("dfs.client.block.recovery.retries", 2);
-    conf.setInt("hbase.regionserver.flushlogentries", 1);
     TEST_UTIL.startMiniDFSCluster(3);
     TEST_UTIL.setNameNodeNameSystemLeasePeriod(100, 10000);
     Path hbaseRootDir =