NPE in DisruptorQueue.consumeBatchToCursor

[Andrey Yegorov <an...@gmail.com>]

Got the exception (below) in storm 0.9.2, noticed in the UI.
Any idea what could go wrong in this case, is this something I need to
tweak in topology / config?

java.lang.RuntimeException: java.lang.NullPointerException at
backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:128)
at
backtype.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:99)
at
backtype.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:80)
at
backtype.storm.disruptor$consume_loop_STAR_$fn__758.invoke(disruptor.clj:94)
at backtype.storm.util$async_loop$fn__457.invoke(util.clj:431) at
clojure.lang.AFn.run(AFn.java:24) at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.NullPointerException at
clojure.lang.RT.intCast(RT.java:1087) at
backtype.storm.daemon.worker$mk_transfer_fn$fn__5748.invoke(worker.clj:128)
at
backtype.storm.daemon.executor$start_batch_transfer__GT_worker_handler_BANG_$fn__5483.invoke(executor.clj:256)
at
backtype.storm.disruptor$clojure_handler$reify__745.onEvent(disruptor.clj:58)
at
backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:125)
... 6 more


----------
Andrey Yegorov