Merge pull request #392 from liquidm/improve_realtime_metrics

consider errors in reading from firehose as unparsable
This commit is contained in:
fjy 2014-02-11 09:42:19 -07:00
commit 9c55e2b779
1 changed files with 2 additions and 2 deletions

View File

@ -182,8 +182,8 @@ public class RealtimeManager implements QuerySegmentWalker
inputRow = firehose.nextRow();
}
catch (Exception e) {
log.info(e, "thrown away line due to exception");
metrics.incrementThrownAway();
log.debug(e, "thrown away line due to exception, considering unparseable");
metrics.incrementUnparseable();
continue;
}