hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From st...@apache.org
Subject svn commit: r1196221 - in /hbase/branches/0.92: CHANGES.txt src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
Date Tue, 01 Nov 2011 19:12:50 GMT
Author: stack
Date: Tue Nov  1 19:12:50 2011
New Revision: 1196221

URL: http://svn.apache.org/viewvc?rev=1196221&view=rev
Log:
HBASE-4695  WAL logs get deleted before region server can fully flush

Modified:
    hbase/branches/0.92/CHANGES.txt
    hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java

Modified: hbase/branches/0.92/CHANGES.txt
URL: http://svn.apache.org/viewvc/hbase/branches/0.92/CHANGES.txt?rev=1196221&r1=1196220&r2=1196221&view=diff
==============================================================================
--- hbase/branches/0.92/CHANGES.txt (original)
+++ hbase/branches/0.92/CHANGES.txt Tue Nov  1 19:12:50 2011
@@ -397,6 +397,8 @@ Release 0.92.0 - Unreleased
                slowing down the shutdown by 0.5s
    HBASE-4552  multi-CF bulk load is not atomic across column families (Jonathan Hsieh)
    HBASE-4710  UnknownProtocolException should abort client retries
+   HBASE-4695  WAL logs get deleted before region server can fully flush
+               (gaojinchao)
 
   TESTS
    HBASE-4492  TestRollingRestart fails intermittently

Modified: hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java?rev=1196221&r1=1196220&r2=1196221&view=diff
==============================================================================
--- hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
(original)
+++ hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
Tue Nov  1 19:12:50 2011
@@ -708,12 +708,10 @@ public class HRegionServer implements HR
     } else if (abortRequested) {
       if (this.fsOk) {
         closeAllRegions(abortRequested); // Don't leave any open file handles
-        closeWAL(false);
       }
       LOG.info("aborting server " + this.serverNameFromMasterPOV);
     } else {
       closeAllRegions(abortRequested);
-      closeWAL(true);
       closeAllScanners();
       LOG.info("stopping server " + this.serverNameFromMasterPOV);
     }
@@ -725,7 +723,12 @@ public class HRegionServer implements HR
       LOG.info("stopping server " + this.serverNameFromMasterPOV +
         "; all regions closed.");
     }
-
+    
+    //fsOk flag may be changed when closing regions throws exception. 
+    if (!this.killed && this.fsOk) {
+      closeWAL(abortRequested ? false : true);
+    }
+    
     // Make sure the proxy is down.
     if (this.hbaseMaster != null) {
       HBaseRPC.stopProxy(this.hbaseMaster);



Mime
View raw message