I just started using storm and created sample java project with following
maven dependency
<dependencies>
<dependency>
<groupId>org.apache.storm</groupId>
<artifactId>storm-core</artifactId>
<version>0.9.5</version>
</dependency>
</dependencies>
However when I run the program with LocalCluster (local mode), I get
following error. Any help. Do I need to explicitly add this dependency
in maven?
java.lang.NoClassDefFoundError: carbonite/JavaBridge
at
backtype.storm.serialization.SerializationFactory.getKryo(SerializationFactory.java:73)
~[storm-core-0.9.5.jar:0.9.5]
at
backtype.storm.serialization.KryoValuesDeserializer.<init>(KryoValuesDeserializer.java:33)
~[storm-core-0.9.5.jar:0.9.5]
at
backtype.storm.serialization.KryoTupleDeserializer.<init>(KryoTupleDeserializer.java:39)
~[storm-core-0.9.5.jar:0.9.5]
at
backtype.storm.daemon.executor$mk_executor_data$fn__3276.invoke(executor.clj:214)
~[storm-core-0.9.5.jar:0.9.5]
at backtype.storm.util$assoc_apply_self.invoke(util.clj:850)
~[storm-core-0.9.5.jar:0.9.5]
at
backtype.storm.daemon.executor$mk_executor_data.invoke(executor.clj:214)
~[storm-core-0.9.5.jar:0.9.5]
at backtype.storm.daemon.executor$mk_executor.invoke(executor.clj:319)
~[storm-core-0.9.5.jar:0.9.5]
at
backtype.storm.daemon.worker$fn__4629$exec_fn__1104__auto____4630$iter__4635__4639$fn__4640.invoke(worker.clj:424)
~[storm-core-0.9.5.jar:0.9.5]
at clojure.lang.LazySeq.sval(LazySeq.java:42) [clojure-1.5.1.jar:na]
at clojure.lang.LazySeq.seq(LazySeq.java:60) [clojure-1.5.1.jar:na]
at clojure.lang.RT.seq(RT.java:484) [clojure-1.5.1.jar:na]
at clojure.core$seq.invoke(core.clj:133) [clojure-1.5.1.jar:na]
at clojure.core$dorun.invoke(core.clj:2780) [clojure-1.5.1.jar:na]
at clojure.core$doall.invoke(core.clj:2796) [clojure-1.5.1.jar:na]
at
backtype.storm.daemon.worker$fn__4629$exec_fn__1104__auto____4630.invoke(worker.clj:424)
~[storm-core-0.9.5.jar:0.9.5]
at clojure.lang.AFn.applyToHelper(AFn.java:185) [clojure-1.5.1.jar:na]
at clojure.lang.AFn.applyTo(AFn.java:151) [clojure-1.5.1.jar:na]
at clojure.core$apply.invoke(core.clj:617) [clojure-1.5.1.jar:na]
at
backtype.storm.daemon.worker$fn__4629$mk_worker__4685.doInvoke(worker.clj:391)
[storm-core-0.9.5.jar:0.9.5]
at clojure.lang.RestFn.invoke(RestFn.java:512) [clojure-1.5.1.jar:na]
at backtype.storm.daemon.supervisor$fn__5186.invoke(supervisor.clj:620)
[storm-core-0.9.5.jar:0.9.5]
at clojure.lang.MultiFn.invoke(MultiFn.java:241) [clojure-1.5.1.jar:na]
at
backtype.storm.daemon.supervisor$sync_processes$iter__5009__5013$fn__5014$fn__5024.invoke(supervisor.clj:305)
[storm-core-0.9.5.jar:0.9.5]
at
backtype.storm.daemon.supervisor$sync_processes$iter__5009__5013$fn__5014.invoke(supervisor.clj:295)
[storm-core-0.9.5.jar:0.9.5]
at clojure.lang.LazySeq.sval(LazySeq.java:42) [clojure-1.5.1.jar:na]
at clojure.lang.LazySeq.seq(LazySeq.java:60) [clojure-1.5.1.jar:na]
at clojure.lang.RT.seq(RT.java:484) [clojure-1.5.1.jar:na]
at clojure.core$seq.invoke(core.clj:133) [clojure-1.5.1.jar:na]
at clojure.core$dorun.invoke(core.clj:2780) [clojure-1.5.1.jar:na]
at clojure.core$doall.invoke(core.clj:2796) [clojure-1.5.1.jar:na]
at
backtype.storm.daemon.supervisor$sync_processes.invoke(supervisor.clj:293)
[storm-core-0.9.5.jar:0.9.5]
at clojure.lang.AFn.applyToHelper(AFn.java:161) [clojure-1.5.1.jar:na]
at clojure.lang.AFn.applyTo(AFn.java:151) [clojure-1.5.1.jar:na]
at clojure.core$apply.invoke(core.clj:619) [clojure-1.5.1.jar:na]
at clojure.core$partial$fn__4190.doInvoke(core.clj:2396)
[clojure-1.5.1.jar:na]
at clojure.lang.RestFn.invoke(RestFn.java:397) [clojure-1.5.1.jar:na]
at backtype.storm.event$event_manager$fn__2465.invoke(event.clj:40)
[storm-core-0.9.5.jar:0.9.5]
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_80]
