From 2306a7fd9666b0cbc66f8a9a49d676e32de087de Mon Sep 17 00:00:00 2001
From: tedyu <yuzhihong@gmail.com>
Date: Fri, 5 Dec 2014 18:40:50 -0800
Subject: [PATCH] HBASE-12642 LoadIncrementalHFiles does not throw exception
 after hitting hbase.bulkload.retries.number setting

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

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 8376e8556c8..55374b22cb4 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++;