You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by to...@apache.org on 2011/08/30 23:23:49 UTC

svn commit: r1163396 - in /hbase/branches/0.90: CHANGES.txt src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLogSplitter.java

Author: todd
Date: Tue Aug 30 21:23:48 2011
New Revision: 1163396

URL: http://svn.apache.org/viewvc?rev=1163396&view=rev
Log:
HBASE-4294  HLogSplitter sleeps with 1-second granularity

Modified:
    hbase/branches/0.90/CHANGES.txt
    hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLogSplitter.java

Modified: hbase/branches/0.90/CHANGES.txt
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/CHANGES.txt?rev=1163396&r1=1163395&r2=1163396&view=diff
==============================================================================
--- hbase/branches/0.90/CHANGES.txt (original)
+++ hbase/branches/0.90/CHANGES.txt Tue Aug 30 21:23:48 2011
@@ -29,6 +29,7 @@ Release 0.90.5 - Unreleased
    HBASE-4252  TestLogRolling's low-probability failure (Jieshan Bean)
    HBASE-4269  Add tests and restore semantics to TableInputFormat/TableRecordReader
                (Jonathan Hsieh)
+   HBASE-4294  HLogSplitter sleeps with 1-second granularity (todd)
 
   IMPROVEMENT
    HBASE-4205  Enhance HTable javadoc (Eric Charles)

Modified: hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLogSplitter.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLogSplitter.java?rev=1163396&r1=1163395&r2=1163396&view=diff
==============================================================================
--- hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLogSplitter.java (original)
+++ hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLogSplitter.java Tue Aug 30 21:23:48 2011
@@ -693,7 +693,10 @@ public class HLogSplitter {
     }
     
     void finish() {
-      shouldStop = true;
+      synchronized (dataAvailable) {
+        shouldStop = true;
+        dataAvailable.notifyAll();
+      }
     }
   }