Apache/druid
1
0
Fork 0
mirror of https://github.com/apache/druid.git synced 2025-02-14 05:54:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix hadoop intake's parser exception catching (was too specific)

Browse Source
This commit is contained in:
Hagen Rother 2013-12-19 06:54:04 +01:00
parent 25c3f28907
commit 52746b8ea6
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 {
inputRow = parser.parse(value.toString());
}
catch (IllegalArgumentException e) {
catch (Exception e) {
if (config.isIgnoreInvalidRows()) {
context.getCounter(HadoopDruidIndexerConfig.IndexJobCounters.INVALID_ROW_COUNTER).increment(1);
return; // we're ignoring this invalid row