hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From t...@apache.org
Subject svn commit: r1086724 - in /hbase/trunk: CHANGES.txt src/main/java/org/apache/hadoop/hbase/mapreduce/ImportTsv.java
Date Tue, 29 Mar 2011 20:26:52 GMT
Author: todd
Date: Tue Mar 29 20:26:52 2011
New Revision: 1086724

URL: http://svn.apache.org/viewvc?rev=1086724&view=rev
Log:
HBASE-3711  importtsv fails if rowkey length exceeds MAX_ROW_LENGTH

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

Modified: hbase/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hbase/trunk/CHANGES.txt?rev=1086724&r1=1086723&r2=1086724&view=diff
==============================================================================
--- hbase/trunk/CHANGES.txt (original)
+++ hbase/trunk/CHANGES.txt Tue Mar 29 20:26:52 2011
@@ -52,6 +52,8 @@ Release 0.91.0 - Unreleased
    HBASE-3688  Setters of class HTableDescriptor do not work properly
    HBASE-3702  Fix NPE in Exec method parameter serialization
    HBASE-3709  HFile compression not sharing configuration
+   HBASE-3711  importtsv fails if rowkey length exceeds MAX_ROW_LENGTH
+               (Kazuki Ohta via todd)
 
   IMPROVEMENTS
    HBASE-3290  Max Compaction Size (Nicolas Spiegelberg via Stack)  

Modified: hbase/trunk/src/main/java/org/apache/hadoop/hbase/mapreduce/ImportTsv.java
URL: http://svn.apache.org/viewvc/hbase/trunk/src/main/java/org/apache/hadoop/hbase/mapreduce/ImportTsv.java?rev=1086724&r1=1086723&r2=1086724&view=diff
==============================================================================
--- hbase/trunk/src/main/java/org/apache/hadoop/hbase/mapreduce/ImportTsv.java (original)
+++ hbase/trunk/src/main/java/org/apache/hadoop/hbase/mapreduce/ImportTsv.java Tue Mar 29
20:26:52 2011
@@ -267,6 +267,16 @@ public class ImportTsv {
         } else {
           throw new IOException(badLine);
         }
+      } catch (IllegalArgumentException e) {
+        if (skipBadLines) {
+          System.err.println(
+              "Bad line at offset: " + offset.get() + ":\n" +
+              badLine.getMessage());
+          badLineCount.increment(1);
+          return;
+        } else {
+          throw new IOException(badLine);
+        }
       } catch (InterruptedException e) {
         e.printStackTrace();
       }



Mime
View raw message