java.lang.ArrayIndexOutOfBoundsException: 3 at backtype.storm.utils.DisruptorQueue.consumeBatchToCursor

[Kushan Maskey <ku...@mmillerassociates.com>]

I am getting this error message in the Storm UI. Topology works fine on
localCluster.


java.lang.RuntimeException: java.lang.ArrayIndexOutOfBoundsException: 3 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.daemon.executor$fn__5641$fn__5653$fn__5700.invoke(executor.clj:746)
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:744)
Caused by: java.lang.ArrayIndexOutOfBoundsException: 3 at <my
package>.method(<My Class>.java:135) at <My
Class>.method(<MyClass>.java:83) at <MyBolt>.execute(<MyBolt>.java:56) at
backtype.storm.topology.BasicBoltExecutor.execute(BasicBoltExecutor.java:50)
at
backtype.storm.daemon.executor$fn__5641$tuple_action_fn__5643.invoke(executor.clj:631)
at
backtype.storm.daemon.executor$mk_task_receiver$fn__5564.invoke(executor.clj:399)
at
backtype.storm.disruptor$clojure_handler$reify__745.onEvent(disruptor.clj:58)
at
backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:125)
... 6 more


I am wondering if it has to do with curator version. Coz the storm
distribution comes with curator 2.4.0 and i think we have to use curator
2.5.0.

I am using storm 0.9.2 with kafka_2.10-0.8.1.1, zookeeper 3.4.5.

--
Kushan Maskey
817.403.7500