Hi,

My topology was working fine with storm 0.9.3 on jvm-7 When I upgraded to
storm 0.9.5 and vm-8 cluster I get the following exception in UI. I am
using statsD for metrics but even disabling that does not help. Here are
some relevant dependencies

"org.apache.storm" % "storm-core" % "0.9.5" % "provided",
"org.apache.storm" % "storm-kafka" % "0.9.5",
"com.timgroup" % "java-statsd-client" % "3.1.0",

java.lang.RuntimeException: Cannot get field 'bolt' because union is
currently set to spout at
backtype.storm.generated.ExecutorSpecificStats.get_bolt(ExecutorSpecificStats.java:245)
at
backtype.storm.ui.core$aggregate_bolt_stats$fn__5558.invoke(core.clj:173)
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_bolt_stats.invoke(core.clj:173) at
backtype.storm.ui.core$compute_executor_capacity.invoke(core.clj:274) 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.RT.seq(RT.java:484) at clojure.core$seq.invoke(core.clj:133)
at clojure.core$apply.invoke(core.clj:617) at
backtype.storm.ui.core$compute_bolt_capacity.invoke(core.clj:288) at
backtype.storm.ui.core$visualization_data$iter__5671__5675$fn__5676.invoke(core.clj:399)
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$dorun.invoke(core.clj:2780) at
clojure.core$doall.invoke(core.clj:2796) at
backtype.storm.ui.core$visualization_data.invoke(core.clj:434) at
backtype.storm.ui.core$topology_page.invoke(core.clj:642) at
backtype.storm.ui.core$fn__6096.invoke(core.clj:853) at
compojure.core$make_route$fn__4275.invoke(core.clj:93) at
compojure.core$if_route$fn__4263.invoke(core.clj:39) at
compojure.core$if_method$fn__4256.invoke(core.clj:24) at
compojure.core$routing$fn__4281.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__4285.invoke(core.clj:111) at
ring.middleware.reload$wrap_reload$fn__4310.invoke(reload.clj:14) at
backtype.storm.ui.core$catch_errors$fn__6135.invoke(core.clj:909) at
ring.middleware.keyword_params$wrap_keyword_params$fn__4952.invoke(keyword_params.clj:27)
at
ring.middleware.nested_params$wrap_nested_params$fn__4991.invoke(nested_params.clj:65)
at ring.middleware.params$wrap_params$fn__4924.invoke(params.clj:55) at
ring.middleware.multipart_params$wrap_multipart_params$fn__5019.invoke(multipart_params.clj:103)
at ring.middleware.flash$wrap_flash$fn__5200.invoke(flash.clj:14) at
ring.middleware.session$wrap_session$fn__5189.invoke(session.clj:43) at
ring.middleware.cookies$wrap_cookies$fn__5120.invoke(cookies.clj:160) at
ring.adapter.jetty$proxy_handler$fn__5400.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)

Regards

Naresh

Reply via email to