Nick Cuneo created STORM-2132:
---------------------------------
Summary: NullPointerException in KafkaSpout
Key: STORM-2132
URL: https://issues.apache.org/jira/browse/STORM-2132
Project: Apache Storm
Issue Type: Bug
Components: storm-kafka
Affects Versions: 1.0.2
Reporter: Nick Cuneo
Received a null pointer exception using storm-kafka-client. Not sure what
caused it, was just sitting idle in my IDE. It did crash my topology.
Here's the consumer information:
topic 0 1,546 2,802 2,798 4
topic 1 1,663 2,856 2,856 0
topic 2 1,671 3,031 3,022 9
topic 3 1,648 2,760 2,760 0
topic 4 1,618 2,828 2,824 4
topic 5 1,537 2,599 2,595 4
topic 6 1,469 2,522 2,522 0
java.lang.NullPointerException
at
org.apache.storm.kafka.spout.KafkaSpout.doSeekRetriableTopicPartitions(KafkaSpout.java:249)
at
org.apache.storm.kafka.spout.KafkaSpout.pollKafkaBroker(KafkaSpout.java:237)
at
org.apache.storm.kafka.spout.KafkaSpout.nextTuple(KafkaSpout.java:203)
at
org.apache.storm.daemon.executor$fn__7990$fn__8005$fn__8036.invoke(executor.clj:648)
at org.apache.storm.util$async_loop$fn__624.invoke(util.clj:484)
at clojure.lang.AFn.run(AFn.java:22)
at java.lang.Thread.run(Thread.java:745)
[Thread-34-kafka-spout-executor[4 5]] ERROR org.apache.storm.daemon.executor -
java.lang.NullPointerException
at
org.apache.storm.kafka.spout.KafkaSpout.doSeekRetriableTopicPartitions(KafkaSpout.java:249)
at
org.apache.storm.kafka.spout.KafkaSpout.pollKafkaBroker(KafkaSpout.java:237)
at
org.apache.storm.kafka.spout.KafkaSpout.nextTuple(KafkaSpout.java:203)
at
org.apache.storm.daemon.executor$fn__7990$fn__8005$fn__8036.invoke(executor.clj:648)
at org.apache.storm.util$async_loop$fn__624.invoke(util.clj:484)
at clojure.lang.AFn.run(AFn.java:22)
at java.lang.Thread.run(Thread.java:745)
[Thread-34-kafka-spout-executor[4 5]] ERROR org.apache.storm.util - Halting
process: ("Worker died")
java.lang.RuntimeException: ("Worker died")
at org.apache.storm.util$exit_process_BANG_.doInvoke(util.clj:341)
at clojure.lang.RestFn.invoke(RestFn.java:423)
at
org.apache.storm.daemon.worker$fn__8659$fn__8660.invoke(worker.clj:761)
at
org.apache.storm.daemon.executor$mk_executor_data$fn__7875$fn__7876.invoke(executor.clj:274)
at org.apache.storm.util$async_loop$fn__624.invoke(util.clj:494)
at clojure.lang.AFn.run(AFn.java:22)
at java.lang.Thread.run(Thread.java:745)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
