Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

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

This commit is contained in:
tedyu 2014-12-05 18:39:58 -08:00
parent 1ec6609b97
commit 415ad6b686
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java
View File

@ -308,8 +308,8 @@ public class LoadIncrementalHFiles extends Configured implements Tool {
int maxRetries = getConf().getInt("hbase.bulkload.retries.number", 0); int maxRetries = getConf().getInt("hbase.bulkload.retries.number", 0);
if (maxRetries != 0 && count >= maxRetries) { if (maxRetries != 0 && count >= maxRetries) {
LOG.error("Retry attempted " + count + " times without completing, bailing out"); throw new IOException("Retry attempted " + count +
return; " times without completing, bailing out");
} }
count++; count++;