1
私の最初の嵐でこの問題が発生しました&カフカの例です。これはclojure-1.4.0.jarの欠落のためです。しかし、私はそれをビルドパスに追加しましたプロジェクト。
9649 [main] ERROR org.apache.zookeeper.server.NIOServerCnxn - Thread Thread[main,5,main] died
java.lang.ExceptionInInitializerError: null
at storm.topology.MyKafkaTopology.main(MyKafkaTopology.java:62) ~[classes/:na]
Caused by: clojure.lang.Compiler$CompilerException: java.lang.NoClassDefFoundError: com/esotericsoftware/kryo/io/Input, compiling:(backtype/storm/daemon/executor.clj:481)
at clojure.lang.Compiler.analyzeSeq(Compiler.java:6462) ~[clojure-1.4.0.jar:na]
at clojure.lang.Compiler.analyze(Compiler.java:6262) ~[clojure-1.4.0.jar:na]
at clojure.lang.Compiler.analyzeSeq(Compiler.java:6443) ~[clojure-1.4.0.jar:na]
at clojure.lang.Compiler.analyze(Compiler.java:6262) ~[clojure-1.4.0.jar:na]
at clojure.lang.Compiler.analyze(Compiler.java:6223) ~[clojure-1.4.0.jar:na]
at clojure.lang.Compiler$IfExpr$Parser.parse(Compiler.java:2642) ~[clojure-1.4.0.jar:na]
at clojure.lang.Compiler.analyzeSeq(Compiler.java:6455) ~[clojure-1.4.0.jar:na]
at clojure.lang.Compiler.analyze(Compiler.java:6262) ~[clojure-1.4.0.jar:na]
at clojure.lang.Compiler.access$100(Compiler.java:37) ~[clojure-1.4.0.jar:na]
at clojure.lang.Compiler$LetExpr$Parser.parse(Compiler.java:5883) ~[clojure-1.4.0.jar:na]
at clojure.lang.Compiler.analyzeSeq(Compiler.java:6455) ~[clojure-1.4.0.jar:na]
at clojure.lang.Compiler.analyze(Compiler.java:6262) ~[clojure-1.4.0.jar:na]
at clojure.lang.Compiler.analyzeSeq(Compiler.java:6443) ~[clojure-1.4.0.jar:na]
at clojure.lang.Compiler.analyze(Compiler.java:6262) ~[clojure-1.4.0.jar:na]
at clojure.lang.Compiler.analyze(Compiler.java:6223) ~[clojure-1.4.0.jar:na]
at clojure.lang.Compiler$BodyExpr$Parser.parse(Compiler.java:5618) ~[clojure-1.4.0.jar:na]
at clojure.lang.Compiler$FnMethod.parse(Compiler.java:5054) ~[clojure-1.4.0.jar:na]
at clojure.lang.Compiler$FnExpr.parse(Compiler.java:3674) ~[clojure-1.4.0.jar:na]
at clojure.lang.Compiler.analyzeSeq(Compiler.java:6453) ~[clojure-1.4.0.jar:na]
at clojure.lang.Compiler.analyze(Compiler.java:6262) ~[clojure-1.4.0.jar:na]
at clojure.lang.Compiler.analyzeSeq(Compiler.java:6443) ~[clojure-1.4.0.jar:na]
at clojure.lang.Compiler.analyze(Compiler.java:6262) ~[clojure-1.4.0.jar:na]
at clojure.lang.Compiler.access$100(Compiler.java:37) ~[clojure-1.4.0.jar:na]
at clojure.lang.Compiler$LetExpr$Parser.parse(Compiler.java:5883) ~[clojure-1.4.0.jar:na]
at clojure.lang.Compiler.analyzeSeq(Compiler.java:6455) ~[clojure-1.4.0.jar:na]
at clojure.lang.Compiler.analyze(Compiler.java:6262) ~[clojure-1.4.0.jar:na]
at clojure.lang.Compiler.analyzeSeq(Compiler.java:6443) ~[clojure-1.4.0.jar:na]
at clojure.lang.Compiler.analyze(Compiler.java:6262) ~[clojure-1.4.0.jar:na]
at clojure.lang.Compiler.analyze(Compiler.java:6223) ~[clojure-1.4.0.jar:na]
at clojure.lang.Compiler$BodyExpr$Parser.parse(Compiler.java:5618) ~[clojure-1.4.0.jar:na]
at clojure.lang.Compiler$LetExpr$Parser.parse(Compiler.java:5919) ~[clojure-1.4.0.jar:na]
...
から
storm/topology/MyKafkaTopology
にこれを追加してみてください私はstormcore-0.9.1-incubating.jarの依存関係をダウンロードするのを手伝ってくれました。正しく動作しませんでした。 storm-core-0.9.1-incubating.jarのpom.xmlへの依存関係を削除し、すべてのjarファイルをstorm-0.9.1-incubatingのlibのリソースに追加します。このプロジェクトはうまくいきます。もう一度私の質問に答えるために。 –