svn commit: r1200958 - in /hbase/trunk: CHANGES.txt src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java

[st...@apache.org]

Author: stack
Date: Fri Nov 11 17:09:12 2011
New Revision: 1200958

URL: http://svn.apache.org/viewvc?rev=1200958&view=rev
Log:
HBASE-4734 [bulk load] Warn if bulk load directory contained no files

Modified:
    hbase/trunk/CHANGES.txt
    hbase/trunk/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java

Modified: hbase/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hbase/trunk/CHANGES.txt?rev=1200958&r1=1200957&r2=1200958&view=diff
==============================================================================
--- hbase/trunk/CHANGES.txt (original)
+++ hbase/trunk/CHANGES.txt Fri Nov 11 17:09:12 2011
@@ -465,6 +465,7 @@ Release 0.92.0 - Unreleased
    HBASE-4740  [bulk load] the HBASE-4552 API can't tell if errors on region server are recoverable
                (Jonathan Hsieh)
    HBASE-4741  Online schema change doesn't return errors
+   HBASE-4734  [bulk load] Warn if bulk load directory contained no files
 
   TESTS
    HBASE-4450  test for number of blocks read: to serve as baseline for expected

Modified: hbase/trunk/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java
URL: http://svn.apache.org/viewvc/hbase/trunk/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java?rev=1200958&r1=1200957&r2=1200958&view=diff
==============================================================================
--- hbase/trunk/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java (original)
+++ hbase/trunk/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java Fri Nov 11 17:09:12 2011
@@ -208,6 +208,12 @@ public class LoadIncrementalHFiles exten
         return;
       }
 
+      if (queue.isEmpty()) {
+        LOG.warn("Bulk load operation did not find any files to load in " +
+        "directory " + hfofDir.toUri() + ".  Does it contain files in " +
+        "subdirectories that correspond to column family names?");
+      }
+
       // Assumes that region splits can happen while this occurs.
       while (!queue.isEmpty()) {
         // need to reload split keys each iteration.