Hello all,
I attempt to submit a topology with one spout and two bolts. During
initialization I see that the two bolts start execution normally, but my
spout sends the following error to the Storm UI and does not start
execution:
java.lang.RuntimeException: Cannot get field 'spout' because union is
currently set to bolt
at
backtype.storm.generated.ExecutorSpecificStats.get_spout(ExecutorSpecificStats.java:259)
at
backtype.storm.ui.core$aggregate_spout_stats$fn__7713.invoke(core.clj:197)
at clojure.core$map$fn__4207.invoke(core.clj:2485)
at clojure.lang.LazySeq.sval(LazySeq.java:42)
at clojure.lang.LazySeq.seq(LazySeq.java:60)
at clojure.lang.RT.seq(RT.java:484)
at clojure.core$seq.invoke(core.clj:133)
at clojure.core$map$fn__4207.invoke(core.clj:2479)
at clojure.lang.LazySeq.sval(LazySeq.java:42)
at clojure.lang.LazySeq.seq(LazySeq.java:60)
at clojure.lang.Cons.next(Cons.java:39)
at clojure.lang.RT.boundedLength(RT.java:1654)
at clojure.lang.RestFn.applyTo(RestFn.java:130)
at clojure.core$apply.invoke(core.clj:619)
at backtype.storm.ui.core$aggregate_counts.invoke(core.clj:119)
at backtype.storm.ui.core$aggregate_spout_stats.invoke(core.clj:197)
at backtype.storm.ui.core$spout_streams_stats.invoke(core.clj:298)
at
backtype.storm.ui.core$visualization_data$iter__7803__7807$fn__7808.invoke(core.clj:386)
at clojure.lang.LazySeq.sval(LazySeq.java:42)
at clojure.lang.LazySeq.seq(LazySeq.java:60)
at clojure.lang.Cons.next(Cons.java:39)
at clojure.lang.RT.next(RT.java:598)
at clojure.core$next.invoke(core.clj:64)
at clojure.core$dorun.invoke(core.clj:2781)
at clojure.core$doall.invoke(core.clj:2796)
at backtype.storm.ui.core$visualization_data.invoke(core.clj:412)
at backtype.storm.ui.core$topology_page.invoke(core.clj:601)
at backtype.storm.ui.core$fn__8229.invoke(core.clj:796)
at compojure.core$make_route$fn__3365.invoke(core.clj:93)
at compojure.core$if_route$fn__3353.invoke(core.clj:39)
at compojure.core$if_method$fn__3346.invoke(core.clj:24)
at compojure.core$routing$fn__3371.invoke(core.clj:106)
at clojure.core$some.invoke(core.clj:2443)
at compojure.core$routing.doInvoke(core.clj:106)
at clojure.lang.RestFn.applyTo(RestFn.java:139)
at clojure.core$apply.invoke(core.clj:619)
at compojure.core$routes$fn__3375.invoke(core.clj:111)
at ring.middleware.reload$wrap_reload$fn__7540.invoke(reload.clj:14)
at backtype.storm.ui.core$catch_errors$fn__8268.invoke(core.clj:858)
at
ring.middleware.keyword_params$wrap_keyword_params$fn__4029.invoke(keyword_params.clj:27)
at
ring.middleware.nested_params$wrap_nested_params$fn__4068.invoke(nested_params.clj:65)
at ring.middleware.params$wrap_params$fn__4001.invoke(params.clj:55)
at
ring.middleware.multipart_params$wrap_multipart_params$fn__4096.invoke(multipart_params.clj:103)
at ring.middleware.flash$wrap_flash$fn__4277.invoke(flash.clj:14)
at ring.middleware.session$wrap_session$fn__4266.invoke(session.clj:43)
at ring.middleware.cookies$wrap_cookies$fn__4197.invoke(cookies.clj:160)
at ring.adapter.jetty$proxy_handler$fn__7179.invoke(jetty.clj:16)
at
ring.adapter.jetty.proxy$org.mortbay.jetty.handler.AbstractHandler$0.handle(Unknown
Source)
at
org.mortbay.jetty.handler.HandlerWrapper.handle(HandlerWrapper.java:152)
at org.mortbay.jetty.Server.handle(Server.java:326)
at
org.mortbay.jetty.HttpConnection.handleRequest(HttpConnection.java:542)
at
org.mortbay.jetty.HttpConnection$RequestHandler.headerComplete(HttpConnection.java:928)
at org.mortbay.jetty.HttpParser.parseNext(HttpParser.java:549)
at org.mortbay.jetty.HttpParser.parseAvailable(HttpParser.java:212)
at org.mortbay.jetty.HttpConnection.handle(HttpConnection.java:404)
at
org.mortbay.jetty.bio.SocketConnector$Connection.run(SocketConnector.java:228)
at
org.mortbay.thread.QueuedThreadPool$PoolThread.run(QueuedThreadPool.java:582)
Any indication on what is reason of this exception and where I should look?
Thank you,
Nick
--
Nikolaos Romanos Katsipoulakis,
University of Pittsburgh, PhD candidate
