search

salesforce / storm-dynamic-spout

A framework for building spouts for Apache Storm and a Kafka based spout for dynamically skipping messages to be processed later.
BSD 3-Clause "New" or "Revised" License
41 stars 13 forks source link

RatioMessageBuffer NPEs on Spout deploy #100

Closed Crim closed 6 years ago

Crim commented 6 years ago 
5:44:17.913 ERROR o.a.s.d.executor [Thread-20-example-executor[3 3]]: 
java.lang.NullPointerException: null
    at com.salesforce.storm.spout.dynamic.buffer.RatioMessageBuffer$NextVirtualSpoutIdGenerator.nextVirtualSpoutId(RatioMessageBuffer.java:318) ~[dynamic-spout-0.10-SNAPSHOT.jar:?]
    at com.salesforce.storm.spout.dynamic.buffer.RatioMessageBuffer.poll(RatioMessageBuffer.java:222) ~[dynamic-spout-0.10-SNAPSHOT.jar:?]
    at com.salesforce.storm.spout.dynamic.MessageBus.nextMessage(MessageBus.java:83) ~[dynamic-spout-0.10-SNAPSHOT.jar:?]
    at com.salesforce.storm.spout.dynamic.DynamicSpout.nextTuple(DynamicSpout.java:234) ~[dynamic-spout-0.10-SNAPSHOT.jar:?]
    at org.apache.storm.daemon.executor$fn__4962$fn__4977$fn__5008.invoke(executor.clj:646) ~[storm-core-1.1.1.jar:1.1.1]
    at org.apache.storm.util$async_loop$fn__557.invoke(util.clj:484) [storm-core-1.1.1.jar:1.1.1]
    at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
    at java.lang.Thread.run(Thread.java:748) [?:1.8.0_144]