Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Won't Fix
-
1.0.2
-
None
-
None
Description
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$fn8005$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$fn8005$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)