Index: hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java =================================================================== --- hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java (revision 1481663) +++ hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java (working copy) @@ -314,6 +314,10 @@ LOG.error(err); } } + + if (queue != null && !queue.isEmpty()) { + throw new RuntimeException("Bulk load aborted with some files not yet loaded. Please check log for more details."); + } } /**