PlanetJava
Custom Search

java-clojure-storm
[Top] [All Lists]

Kafka Spout Error - ClassNotFoundException: storm.trident.spout.ISpoutPa

Subject: Kafka Spout Error - ClassNotFoundException: storm.trident.spout.ISpoutPartition
Date: Thu, 7 Mar 2013 11:32:47 -0800 (PST)
Hi All,
I am attempting to establish a Kafka Spout reading messages off a local 
Kafka instance. Here is my configuration:
Storm: 0.8.1
Kafka: 0.7.2-incubating
Kafka-Storm Client: storm-kafka-0.9.0-wip3.jar
Zookeeper: 3.3.4
It appears that interface ISpoutPartition is missing. Can someone please 
point me to the correct trident or kafka-storm source or jar?
Stack trace:
2755 [Thread-9] ERROR backtype.storm.daemon.executor  - 
java.lang.NoClassDefFoundError: storm/trident/spout/ISpoutPartition
at java.lang.ClassLoader.defineClass1(Native Method)
at java.lang.ClassLoader.defineClassCond(ClassLoader.java:631)
at java.lang.ClassLoader.defineClass(ClassLoader.java:615)
at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:141)
at java.net.URLClassLoader.defineClass(URLClassLoader.java:283)
at java.net.URLClassLoader.access$000(URLClassLoader.java:58)
at java.net.URLClassLoader$1.run(URLClassLoader.java:197)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:190)
at java.lang.ClassLoader.loadClass(ClassLoader.java:306)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301)
at java.lang.ClassLoader.loadClass(ClassLoader.java:247)
at storm.kafka.StaticCoordinator.<init>(StaticCoordinator.java:19)
at storm.kafka.KafkaSpout.open(KafkaSpout.java:72)
at backtype.storm.daemon.executor$fn__3976.invoke(executor.clj:415)
at clojure.lang.MultiFn.invoke(MultiFn.java:167)
at 
backtype.storm.daemon.executor$mk_executor$fn__3915.invoke(executor.clj:249)
at backtype.storm.daemon.executor$mk_executor.invoke(executor.clj:248)
at 
backtype.storm.daemon.worker$fn__4324$exec_fn__1207__auto____4325$iter__4330__4334$fn__4335.invoke(worker.clj:353)
at clojure.lang.LazySeq.sval(LazySeq.java:42)
at clojure.lang.LazySeq.seq(LazySeq.java:60)
at clojure.lang.RT.seq(RT.java:473)
at clojure.core$seq.invoke(core.clj:133)
at clojure.core$dorun.invoke(core.clj:2725)
at clojure.core$doall.invoke(core.clj:2741)
at 
backtype.storm.daemon.worker$fn__4324$exec_fn__1207__auto____4325.invoke(worker.clj:353)
at clojure.lang.AFn.applyToHelper(AFn.java:185)
at clojure.lang.AFn.applyTo(AFn.java:151)
at clojure.core$apply.invoke(core.clj:601)
at 
backtype.storm.daemon.worker$fn__4324$mk_worker__4380.doInvoke(worker.clj:322)
at clojure.lang.RestFn.invoke(RestFn.java:512)
at backtype.storm.daemon.supervisor$fn__4783.invoke(supervisor.clj:457)
at clojure.lang.MultiFn.invoke(MultiFn.java:177)
at 
backtype.storm.daemon.supervisor$sync_processes$iter__4660__4664$fn__4665.invoke(supervisor.clj:247)
at clojure.lang.LazySeq.sval(LazySeq.java:42)
at clojure.lang.LazySeq.seq(LazySeq.java:60)
at clojure.lang.RT.seq(RT.java:473)
at clojure.core$seq.invoke(core.clj:133)
at clojure.core$dorun.invoke(core.clj:2725)
at clojure.core$doall.invoke(core.clj:2741)
at 
backtype.storm.daemon.supervisor$sync_processes.invoke(supervisor.clj:235)
at clojure.lang.AFn.applyToHelper(AFn.java:161)
at clojure.lang.AFn.applyTo(AFn.java:151)
at clojure.core$apply.invoke(core.clj:603)
at clojure.core$partial$fn__4070.doInvoke(core.clj:2343)
at clojure.lang.RestFn.invoke(RestFn.java:397)
at backtype.storm.event$event_manager$fn__2484.invoke(event.clj:24)
at clojure.lang.AFn.run(AFn.java:24)
at java.lang.Thread.run(Thread.java:662)
Caused by: java.lang.ClassNotFoundException: 
storm.trident.spout.ISpoutPartition
at java.net.URLClassLoader$1.run(URLClassLoader.java:202)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:190)
at java.lang.ClassLoader.loadClass(ClassLoader.java:306)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301)
at java.lang.ClassLoader.loadClass(ClassLoader.java:247)
... 49 more
-- 
You received this message because you are subscribed to the Google Groups 
"storm-user" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to storm-user+unsubscribe-/JYPxA39Uh5TLH3MbocFF+G/[email protected]
For more options, visit https://groups.google.com/groups/opt_out.
msgmiddle
<Prev in Thread] Current Thread [Next in Thread>
  • Kafka Spout Error - ClassNotFoundException: storm.trident.spout.ISpoutPartition,
Current Sitemap | © 2012 planetjava | Contact | Privacy Policy