From afff15da51935f4ec895b67d5c0605ab23f4b0be Mon Sep 17 00:00:00 2001 From: Bhupendra Date: Tue, 8 Sep 2015 18:05:44 +0530 Subject: [PATCH] HBASE-14380: Correct data also getting skipped along with bad data in importTsv bulk load thru TsvImporterTextMapper --- .../main/java/org/apache/hadoop/hbase/mapreduce/TextSortReducer.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/TextSortReducer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/TextSortReducer.java index 0aaeeb0..5056f0b 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/TextSortReducer.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/TextSortReducer.java @@ -189,14 +189,14 @@ public class TextSortReducer extends if (skipBadLines) { System.err.println("Bad line." + badLine.getMessage()); incrementBadLineCount(1); - return; + continue; } throw new IOException(badLine); } catch (IllegalArgumentException e) { if (skipBadLines) { System.err.println("Bad line." + e.getMessage()); incrementBadLineCount(1); - return; + continue; } throw new IOException(e); } -- 1.8.4.msysgit.0