You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Pascal Arnal <pa...@wantedanalytics.com> on 2014/08/11 14:38:23 UTC
Error NoSuchElementException
Hi,
I try to run one topology in 0.9.2 and I get one NoSuchElementException :
java.lang.RuntimeException: java.util.NoSuchElementException
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.util.NoSuchElementException
at java.util.AbstractList$Itr.next(AbstractList.java:364)
at com.esotericsoftware.kryo.serializers.CollectionSerializer.write(CollectionSerializer.java:74)
at com.esotericsoftware.kryo.serializers.CollectionSerializer.write(CollectionSerializer.java:18)
at com.esotericsoftware.kryo.Kryo.writeObject(Kryo.java:486)
at backtype.storm.serialization.KryoValuesSerializer.serializeInto(KryoValuesSerializer.java:44)
at backtype.storm.serialization.KryoTupleSerializer.serialize(KryoTupleSerializer.java:44)
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
Can you tell me what is the root cause of this exception ?
Thanks
RE: Error NoSuchElementException
Posted by Pascal Arnal <pa...@wantedanalytics.com>.
I found my problem.
I returned 2 values in one bolt when it expect 3 values...
However, Storm exception is not clear.
________________________________
De : Pascal Arnal <pa...@wantedanalytics.com>
Envoyé : 11 août 2014 08:38
À : user@storm.incubator.apache.org
Objet : Error NoSuchElementException
Hi,
I try to run one topology in 0.9.2 and I get one NoSuchElementException :
java.lang.RuntimeException: java.util.NoSuchElementException
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.util.NoSuchElementException
at java.util.AbstractList$Itr.next(AbstractList.java:364)
at com.esotericsoftware.kryo.serializers.CollectionSerializer.write(CollectionSerializer.java:74)
at com.esotericsoftware.kryo.serializers.CollectionSerializer.write(CollectionSerializer.java:18)
at com.esotericsoftware.kryo.Kryo.writeObject(Kryo.java:486)
at backtype.storm.serialization.KryoValuesSerializer.serializeInto(KryoValuesSerializer.java:44)
at backtype.storm.serialization.KryoTupleSerializer.serialize(KryoTupleSerializer.java:44)
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
Can you tell me what is the root cause of this exception ?
Thanks