mirror of https://github.com/apache/druid.git
consider errors in reading from firehose as unparsable
This commit is contained in:
parent
f7ea50c674
commit
b4eea282b6
|
@ -182,8 +182,8 @@ public class RealtimeManager implements QuerySegmentWalker
|
||||||
inputRow = firehose.nextRow();
|
inputRow = firehose.nextRow();
|
||||||
}
|
}
|
||||||
catch (Exception e) {
|
catch (Exception e) {
|
||||||
log.info(e, "thrown away line due to exception");
|
log.debug(e, "thrown away line due to exception, considering unparseable");
|
||||||
metrics.incrementThrownAway();
|
metrics.incrementUnparseable();
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue