[FLUME-2672] NPE in KafkaSourceCounter

• Type: Bug
• Status: Closed
• Priority: Trivial
• Resolution: Fixed
• Affects Version/s: 1.6.0
• Fix Version/s: 1.7.0
• Component/s: Sinks+Sources
• Labels: easyfix

Environment

Mac OS 10.10.3, Java 1.7.0_60

• Flags: Patch
• Assignee: Rigo MacTaggart
• Reporter: Rigo MacTaggart
• Created: 15/Apr/15 14:25
• Updated: 18/Jun/16 17:30
• Resolved: 16/Sep/15 01:42

Description

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.