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-12642 LoadIncrementalHFiles does not throw exception after hitting hbase.bulkload.retries.number setting
Date Sat, 06 Dec 2014 02:40:56 GMT
Repository: hbase
Updated Branches:
  refs/heads/branch-1 004e977ba -> 2306a7fd9


HBASE-12642 LoadIncrementalHFiles does not throw exception after hitting hbase.bulkload.retries.number
setting


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

Branch: refs/heads/branch-1
Commit: 2306a7fd9666b0cbc66f8a9a49d676e32de087de
Parents: 004e977
Author: tedyu <yuzhihong@gmail.com>
Authored: Fri Dec 5 18:40:50 2014 -0800
Committer: tedyu <yuzhihong@gmail.com>
Committed: Fri Dec 5 18:40:50 2014 -0800

----------------------------------------------------------------------
 .../org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/2306a7fd/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java
index 8376e85..55374b2 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java
@@ -308,8 +308,8 @@ public class LoadIncrementalHFiles extends Configured implements Tool
{
 
         int maxRetries = getConf().getInt("hbase.bulkload.retries.number", 0);
         if (maxRetries != 0 && count >= maxRetries) {
-          LOG.error("Retry attempted " + count +  " times without completing, bailing out");
-          return;
+          throw new IOException("Retry attempted " + count +
+            " times without completing, bailing out");
         }
         count++;
 


Mime
View raw message