Kirill Shirokov created STORM-2040:
--------------------------------------
Summary: Config.TOPOLOGY_TESTING_ALWAYS_TRY_SERIALIZE=true causes
j.l.UnsupportedOperationException: nth not supported on this type:
AddressedTuple
Key: STORM-2040
URL: https://issues.apache.org/jira/browse/STORM-2040
Project: Apache Storm
Issue Type: Bug
Components: storm-core
Affects Versions: 1.0.2, 1.1.0
Environment: Running example topology with local cluster on Windows 7
machine
Reporter: Kirill Shirokov
When Config.TOPOLOGY_TESTING_ALWAYS_TRY_SERIALIZE is enabled for a topology,
the components fail with the following exception:
26168 [Thread-13-disruptor-executor[1 1]-send-queue] ERROR o.a.s.d.executor -
java.lang.RuntimeException: java.lang.UnsupportedOperationException: nth not
supported on this type: AddressedTuple
at
org.apache.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:464)
~[storm-core-1.0.2.jar:1.0.2]
at
org.apache.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:430)
~[storm-core-1.0.2.jar:1.0.2]
at
org.apache.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:73)
~[storm-core-1.0.2.jar:1.0.2]
at
org.apache.storm.disruptor$consume_loop_STAR_$fn__7509.invoke(disruptor.clj:83)
~[storm-core-1.0.2.jar:1.0.2]
at org.apache.storm.util$async_loop$fn__624.invoke(util.clj:484)
[storm-core-1.0.2.jar:1.0.2]
at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_102]
Caused by: java.lang.UnsupportedOperationException: nth not supported on this
type: AddressedTuple
at clojure.lang.RT.nthFrom(RT.java:933) ~[clojure-1.7.0.jar:?]
at clojure.lang.RT.nth(RT.java:883) ~[clojure-1.7.0.jar:?]
at
org.apache.storm.daemon.worker$assert_can_serialize.invoke(worker.clj:130)
~[storm-core-1.0.2.jar:1.0.2]
at
org.apache.storm.daemon.worker$mk_transfer_fn$fn__8214.invoke(worker.clj:202)
~[storm-core-1.0.2.jar:1.0.2]
at
org.apache.storm.daemon.executor$start_batch_transfer__GT_worker_handler_BANG_$fn__7898.invoke(executor.clj:312)
~[storm-core-1.0.2.jar:1.0.2]
at
org.apache.storm.disruptor$clojure_handler$reify__7492.onEvent(disruptor.clj:40)
~[storm-core-1.0.2.jar:1.0.2]
at
org.apache.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:451)
~[storm-core-1.0.2.jar:1.0.2]
... 6 more
26171 [Thread-15-__acker-executor[163 163]] INFO o.a.s.d.executor - Preparing
bolt __acker:(163)
26171 [Thread-15-__acker-executor[163 163]] INFO o.a.s.d.executor - Prepared
bolt __acker:(163)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
