[
https://issues.apache.org/jira/browse/STORM-1747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hugo Louro resolved STORM-1747.
-------------------------------
Resolution: Duplicate
This bug has already been fixed and merged into 1.x-branch. There is currently
a PR based off master.
https://github.com/apache/storm/pull/1382
> storm-kafka-client KafkaSpoutRetryExponentialBackoff throws exception
> ---------------------------------------------------------------------
>
> Key: STORM-1747
> URL: https://issues.apache.org/jira/browse/STORM-1747
> Project: Apache Storm
> Issue Type: Bug
> Reporter: Jifeng Yin
> Assignee: Hugo Louro
>
> {code}
> java.lang.ClassCastException: org.apache.kafka.common.TopicPartition cannot
> be cast to java.lang.Comparable
> at java.util.TreeMap.compare(TreeMap.java:1188) ~[?:1.7.0_80]
> at java.util.TreeMap.put(TreeMap.java:531) ~[?:1.7.0_80]
> at java.util.TreeSet.add(TreeSet.java:255) ~[?:1.7.0_80]
> at
> org.apache.storm.kafka.spout.KafkaSpoutRetryExponentialBackoff.retriableTopicPartitions(KafkaSpoutRetryExponentialBackoff.java:170)
> ~[storm-kafka-client-1.0.0.jar:1.0.0]
> at
> org.apache.storm.kafka.spout.KafkaSpout.doSeekRetriableTopicPartitions(KafkaSpout.java:245)
> ~[storm-kafka-client-1.0.0.jar:1.0.0]
> at
> org.apache.storm.kafka.spout.KafkaSpout.pollKafkaBroker(KafkaSpout.java:236)
> ~[storm-kafka-client-1.0.0.jar:1.0.0]
> at
> org.apache.storm.kafka.spout.KafkaSpout.nextTuple(KafkaSpout.java:202)
> ~[storm-kafka-client-1.0.0.jar:1.0.0]
> at
> org.apache.storm.daemon.executor$fn__7877$fn__7892$fn__7923.invoke(executor.clj:647)
> ~[storm-core-1.0.0.jar:1.0.0]
> at org.apache.storm.util$async_loop$fn__625.invoke(util.clj:484)
> [storm-core-1.0.0.jar:1.0.0]
> at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
> at java.lang.Thread.run(Thread.java:745) [?:1.7.0_80]
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
