Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #337 from liquidm/fix_hadoop_intake_too 

fix hadoop intake's parser exception catching (was too specific)
This commit is contained in:
fjy 2013-12-18 22:08:07 -08:00
parent 25c3f28907 52746b8ea6
commit 4ba8a44239
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
indexing-hadoop/src/main/java/io/druid/indexer/HadoopDruidIndexerMapper.java
View File

@ -62,7 +62,7 @@ public abstract class HadoopDruidIndexerMapper<KEYOUT, VALUEOUT> extends Mapper<
try { try {
inputRow = parser.parse(value.toString()); inputRow = parser.parse(value.toString());
} }
catch (IllegalArgumentException e) { catch (Exception e) {
if (config.isIgnoreInvalidRows()) { if (config.isIgnoreInvalidRows()) {
context.getCounter(HadoopDruidIndexerConfig.IndexJobCounters.INVALID_ROW_COUNTER).increment(1); context.getCounter(HadoopDruidIndexerConfig.IndexJobCounters.INVALID_ROW_COUNTER).increment(1);
return; // we're ignoring this invalid row return; // we're ignoring this invalid row