Uploaded image for project: 'Apache Storm'
  1. Apache Storm
  2. STORM-2040

Config.TOPOLOGY_TESTING_ALWAYS_TRY_SERIALIZE=true causes j.l.UnsupportedOperationException: nth not supported on this type: AddressedTuple

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 1.0.2, 1.1.0
    • Fix Version/s: 2.0.0, 1.1.0, 1.0.3
    • Component/s: storm-core
    • Labels:
      None
    • Environment:
      Running example topology with local cluster on Windows 7 machine

      Description

      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)

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                kabhwan Jungtaek Lim
                Reporter:
                kirill.shirokov Kirill Shirokov
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 0.5h
                  0.5h