Uploaded image for project: 'Apache Storm'
  1. Apache Storm
  2. STORM-2132

NullPointerException in KafkaSpout

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Major
    • Resolution: Won't Fix
    • 1.0.2
    • None
    • storm-kafka
    • 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)

      Attachments

        Activity

          People

            Unassigned Unassigned
            logikz Nick Cuneo
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: