hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From te...@apache.org
Subject hbase git commit: HBASE-15425 Failing to write bulk load event marker in the WAL is ignored (Ashish Singhi)
Date Thu, 10 Mar 2016 15:20:06 GMT
Repository: hbase
Updated Branches:
  refs/heads/branch-1 e103f75ae -> f82147831


HBASE-15425 Failing to write bulk load event marker in the WAL is ignored (Ashish Singhi)


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/f8214783
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/f8214783
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/f8214783

Branch: refs/heads/branch-1
Commit: f82147831b04484ceca17910df67849accb40086
Parents: e103f75
Author: tedyu <yuzhihong@gmail.com>
Authored: Thu Mar 10 07:19:59 2016 -0800
Committer: tedyu <yuzhihong@gmail.com>
Committed: Thu Mar 10 07:19:59 2016 -0800

----------------------------------------------------------------------
 .../java/org/apache/hadoop/hbase/regionserver/HRegion.java    | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/f8214783/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java
index f0be75d..d64798e 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java
@@ -5379,6 +5379,7 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver,
Regi
     Preconditions.checkNotNull(familyPaths);
     // we need writeLock for multi-family bulk load
     startBulkRegionOperation(hasMultipleColumnFamilies(familyPaths));
+    boolean isSuccessful = false;
     try {
       this.writeRequestsCount.increment();
 
@@ -5426,7 +5427,7 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver,
Regi
         // problem when validating
         LOG.warn("There was a recoverable bulk load failure likely due to a" +
             " split.  These (family, HFile) pairs were not loaded: " + list);
-        return false;
+        return isSuccessful;
       }
 
       // We need to assign a sequential ID that's in between two memstores in order to preserve
@@ -5486,7 +5487,7 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver,
Regi
         }
       }
 
-      return true;
+      isSuccessful = true;
     } finally {
       if (wal != null && !storeFiles.isEmpty()) {
         // write a bulk load event when not all hfiles are loaded
@@ -5500,6 +5501,7 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver,
Regi
           if (this.rsServices != null) {
             // Have to abort region server because some hfiles has been loaded but we can't
write
             // the event into WAL
+            isSuccessful = false;
             this.rsServices.abort("Failed to write bulk load event into WAL.", ioe);
           }
         }
@@ -5507,6 +5509,7 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver,
Regi
 
       closeBulkRegionOperation();
     }
+    return isSuccessful;
   }
 
   @Override


Mime
View raw message