Index: hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java =================================================================== --- hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java (revision 1460957) +++ hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java (working copy) @@ -3215,7 +3215,6 @@ IOException ioe = new org.apache.hadoop.hbase.exceptions.DoNotRetryIOException( "No such column family " + Bytes.toStringBinary(familyName)); ioes.add(ioe); - failures.add(p); } else { try { store.assertBulkLoadHFileOk(new Path(path)); @@ -3229,6 +3228,13 @@ } } + // validation failed because of some sort of IO problem. + if (ioes.size() != 0) { + IOException e = MultipleIOException.createIOException(ioes); + LOG.error("There were one or more IO errors when checking if the bulk load is ok.", e); + throw e; + } + // validation failed, bail out before doing anything permanent. if (failures.size() != 0) { StringBuilder list = new StringBuilder(); @@ -3242,13 +3248,6 @@ return false; } - // validation failed because of some sort of IO problem. - if (ioes.size() != 0) { - IOException e = MultipleIOException.createIOException(ioes); - LOG.error("There were one or more IO errors when checking if the bulk load is ok.", e); - throw e; - } - for (Pair p : familyPaths) { byte[] familyName = p.getFirst(); String path = p.getSecond();