Hello again,
So, I spent sometime looking into the logs and I receive the following
exception in each machine that I try to instantiate my spout:
java.lang.RuntimeException: Could not instantiate a class listed in config
under section topology.metrics.consumer.register with fully qualified name
backtype.storm.metrics.LoggingMetricsConsumer
at
backtype.storm.metric.MetricsConsumerBolt.prepare(MetricsConsumerBolt.java:46)
~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
at
backtype.storm.daemon.executor$fn__5641$fn__5653.invoke(executor.clj:690)
~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
at backtype.storm.util$async_loop$fn__457.invoke(util.clj:429)
~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
at clojure.lang.AFn.run(AFn.java:24) [clojure-1.5.1.jar:na]
at java.lang.Thread.run(Thread.java:745) [na:1.7.0_75]
Caused by: java.lang.ClassNotFoundException:
backtype.storm.metrics.LoggingMetricsConsumer
at java.net.URLClassLoader$1.run(URLClassLoader.java:366) ~[na:1.7.0_75]
at java.net.URLClassLoader$1.run(URLClassLoader.java:355) ~[na:1.7.0_75]
at java.security.AccessController.doPrivileged(Native Method)
~[na:1.7.0_75]
at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
~[na:1.7.0_75]
at java.lang.ClassLoader.loadClass(ClassLoader.java:425) ~[na:1.7.0_75]
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
~[na:1.7.0_75]
at java.lang.ClassLoader.loadClass(ClassLoader.java:358) ~[na:1.7.0_75]
at java.lang.Class.forName0(Native Method) ~[na:1.7.0_75]
at java.lang.Class.forName(Class.java:191) ~[na:1.7.0_75]
at
backtype.storm.metric.MetricsConsumerBolt.prepare(MetricsConsumerBolt.java:44)
~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
Why is this happening? Am I lacking some of the classes needed in order to
use the Metrics API?
My storm.yaml for my worker machines has the following lines:
## Metrics Consumers
topology.metrics.consumer.register:
- class: "backtype.storm.metrics.LoggingMetricsConsumer"
parallelism.hint: 1
Does the above exception has anything to do with the version of Storm I am
using (0.9.2)?
Thanks,
Nikos
2015-03-04 13:06 GMT-05:00 Nick R. Katsipoulakis <[email protected]>:
> 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
>
--
Nikolaos Romanos Katsipoulakis,
University of Pittsburgh, PhD candidate
