My storm integration tests work fine on mac, but die on Centos with the
following error:
2014-09-20 21:09:50,499 [Thread-40-enrich] INFO backtype.storm.daemon.task
- Emitting: enrich __ack_ack [-4259171058236784757 5253908046962264078]
2014-09-20 21:09:50,500 [Thread-40-enrich] ERROR backtype.storm.util -
Async loop died!
java.lang.RuntimeException: java.lang.ClassCastException: java.lang.Object
cannot be cast to java.lang.Iterable
at
backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:90)
at
backtype.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:61)
at
backtype.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:62)
at
backtype.storm.daemon.executor$fn__3502$fn__3514$fn__3561.invoke(executor.clj:730)
at backtype.storm.util$async_loop$fn__448.invoke(util.clj:403)
at clojure.lang.AFn.run(AFn.java:24)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.ClassCastException: java.lang.Object cannot be cast to
java.lang.Iterable
at backtype.storm.util$get_iterator.invoke(util.clj:776)
at
backtype.storm.daemon.executor$mk_task_receiver$fn__3425.invoke(executor.clj:379)
at
backtype.storm.disruptor$clojure_handler$reify__2966.onEvent(disruptor.clj:43)
at
backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:82)
... 6 more
2014-09-20 21:09:50,501 [Thread-40-enrich] ERROR
backtype.storm.daemon.executor -
java.lang.RuntimeException: java.lang.ClassCastException: java.lang.Object
cannot be cast to java.lang.Iterable
at
backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:90)
at
backtype.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:61)
at
backtype.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:62)
at
backtype.storm.daemon.executor$fn__3502$fn__3514$fn__3561.invoke(executor.clj:730)
at backtype.storm.util$async_loop$fn__448.invoke(util.clj:403)
at clojure.lang.AFn.run(AFn.java:24)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.ClassCastException: java.lang.Object cannot be cast to
java.lang.Iterable
at backtype.storm.util$get_iterator.invoke(util.clj:776)
at
backtype.storm.daemon.executor$mk_task_receiver$fn__3425.invoke(executor.clj:379)
at
backtype.storm.disruptor$clojure_handler$reify__2966.onEvent(disruptor.clj:43)
at
backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:82)
... 6 more
2014-09-20 21:09:50,515 [Thread-40-enrich] INFO backtype.storm.util -
Halting process: ("Worker died")
2014-09-20 21:09:50,515 [Thread-40-enrich] ERROR
org.apache.zookeeper.server.NIOServerCnxn - Thread
Thread[Thread-40-enrich,5,main] died
Anyone seen anything like this before?
I'm using storm version 0.9.0.1.
Thanks,
Vincent
