[STORM-1725] Kafka Spout New Consumer API - KafkaSpoutRetryExponentialBackoff method should use HashMap instead of TreeMap not to throw Exception

• Type: Bug
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 1.0.0
• Fix Version/s: 1.0.1
• Component/s: storm-kafka-client
• Epic Link: Release Apache Storm 1.0.1
• Assignee: Hugo Da Cruz Louro
• Reporter: Hugo Da Cruz Louro
• Created: 22/Apr/16 17:03
• Updated: 12/Jul/17 06:39
• Resolved: 22/Apr/16 17:32

Description

The method org.apache.storm.kafka.spout.KafkaSpoutRetryExponentialBackoff#retriableTopicPartitions currently uses TreeMap but TopicPartition does not implement Comparable. Since ordering is not important, HashMap is the most appropriate data structure here, and the one I meant to use to begin with.

The fix will replace TreeMap with HashMap.

This issue was found by @jianbzhou and credit should be given to him.

Issue Links

• is duplicated by: STORM-1747 storm-kafka-client KafkaSpoutRetryExponentialBackoff throws exception
• links to: GitHub Pull Request #1382