[jira] [Closed] (STORM-2019) NullPointerException in Kafka-Spout

["zhang shuhao (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/STORM-2019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

zhang shuhao closed STORM-2019.
-------------------------------
    Resolution: Not A Problem

To make a customized kafkaspout, one cannot create container class for kafkaspout class, because it will make tthe kafkaspout thread-unsafe. The correct way is to extend kafkaspout instead.

> NullPointerException in Kafka-Spout
> -----------------------------------
>
>                 Key: STORM-2019
>                 URL: https://issues.apache.org/jira/browse/STORM-2019
>             Project: Apache Storm
>          Issue Type: Bug
>          Components: storm-kafka
>    Affects Versions: 1.0.1
>            Reporter: zhang shuhao
>
> KafkaSpout reports following error:
> java.lang.NullPointerException
>         at java.util.TreeMap.rotateLeft(TreeMap.java:2220) ~[?:1.8.0_77]
>         at java.util.TreeMap.fixAfterInsertion(TreeMap.java:2287) ~[?:1.8.0_77]
>         at java.util.TreeMap.put(TreeMap.java:582) ~[?:1.8.0_77]
>         at org.apache.storm.kafka.PartitionManager.fill(PartitionManager.java:235) ~[stormjar.jar:?]
>         at org.apache.storm.kafka.PartitionManager.next(PartitionManager.java:138) ~[stormjar.jar:?]
>         at org.apache.storm.kafka.KafkaSpout.nextTuple(KafkaSpout.java:135) ~[stormjar.jar:?]
>         at applications.spout.KafkaSpoutWrapper.nextTuple(KafkaSpoutWrapper.java:64) ~[stormjar.jar:?]
>         at org.apache.storm.daemon.executor$fn__7885$fn__7900$fn__7931.invoke(executor.clj:645) ~[storm-core-1.0.1.jar:1.0.1]
>         at org.apache.storm.util$async_loop$fn__625.invoke(util.clj:484) [storm-core-1.0.1.jar:1.0.1]
>         at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
>         at java.lang.Thread.run(Thread.java:745) [?:1.8.0_77]



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)