[ https://issues.apache.org/jira/browse/FLUME-2672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14496248#comment-14496248 ]
Ashish Paliwal commented on FLUME-2672: --------------------------------------- +1, Patch looks good. May be we should have some test cases around counters as well. > NPE in KafkaSourceCounter > ------------------------- > > Key: FLUME-2672 > URL: https://issues.apache.org/jira/browse/FLUME-2672 > Project: Flume > Issue Type: Bug > Components: Sinks+Sources > Affects Versions: v1.6.0 > Environment: Mac OS 10.10.3, Java 1.7.0_60 > Reporter: Rigo MacTaggart > Priority: Trivial > Labels: easyfix > Fix For: v1.6.0 > > Attachments: FLUME-2672.patch > > Original Estimate: 0h > Remaining Estimate: 0h > > A NPE is thrown when KafkaSource calls counter.incrementKafkaEmptyCount() > because it expects MonitoredCounterGroup.counterMap to contain key > "source.kafka.empty.count". A patch is included which adds this key to the > ATTRIBUTES string array, which is used to pre-populate keys with an initial > value. -- This message was sent by Atlassian JIRA (v6.3.4#6332)