From 429af3c9303699293533b1f7825cfa60d43a2151 Mon Sep 17 00:00:00 2001 From: Zhihong Yu Date: Mon, 13 May 2013 17:48:55 +0000 Subject: [PATCH] HBASE-8367 LoadIncrementalHFiles does not return an error code nor throw Exception when failures occur due to timeouts (Brian Dougan) git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1481988 13f79535-47bb-0310-9956-ffa450edef68 --- .../apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java | 5 +++++ 1 file changed, 5 insertions(+) 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 50cc4d3b171..493abd1aef9 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 @@ -314,6 +314,11 @@ public class LoadIncrementalHFiles extends Configured implements Tool { 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."); + } } /**