Hugo Louro created STORM-1725:
---------------------------------

             Summary: Kafka Spout New Consumer API - 
KafkaSpoutRetryExponentialBackoff method should use HashMap instead of TreeMap
                 Key: STORM-1725
                 URL: https://issues.apache.org/jira/browse/STORM-1725
             Project: Apache Storm
          Issue Type: Bug
          Components: storm-kafka
    Affects Versions: 1.0.0
            Reporter: Hugo Louro
            Assignee: Hugo Louro
            Priority: Blocker
             Fix For: 1.0.1


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.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to