You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@storm.apache.org by "Igor Kuzmenko (JIRA)" <ji...@apache.org> on 2017/02/27 16:19:45 UTC
[jira] [Commented] (STORM-2132) NullPointerException in KafkaSpout
[ https://issues.apache.org/jira/browse/STORM-2132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15886051#comment-15886051 ]
Igor Kuzmenko commented on STORM-2132:
--------------------------------------
Fixed in https://issues.apache.org/jira/browse/STORM-2104
> 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.15#6346)