diff --git a/src/main/java/org/apache/hadoop/hbase/mapreduce/ImportTsv.java b/src/main/java/org/apache/hadoop/hbase/mapreduce/ImportTsv.java index b7b8001..beb0233 100644 --- a/src/main/java/org/apache/hadoop/hbase/mapreduce/ImportTsv.java +++ b/src/main/java/org/apache/hadoop/hbase/mapreduce/ImportTsv.java @@ -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(); }