我对 Maven 和 Storm 很陌生,所以我尝试按照 https://github.com/apache/storm/tree/master/examples/storm-starter 中的说明进行操作。 。我当前的路径是/home/luc/theTest/storm/examples/storm-starter。目标文件夹内有一个storm-starter-2.0.0-SNAPSHOT.jar 文件。我运行时卡住了
storm jar target/storm-starter-*.jar org.apache.storm.starter.ExclamationTopology -local
我收到此错误
ionTopology -local Running: /usr/lib/jvm/java-8-openjdk-amd64/bin/java -client -Ddaemon.name= -Dstorm.options= -Dstorm.home=/home/luc/stormTest/apache-storm-1.1.1 -Dstorm.log.dir=/home/luc/stormTest/apache-storm-1.1.1/logs -Djava.library.path=/usr/local/lib:/opt/local/lib:/usr/lib -Dstorm.conf.file= -cp /home/luc/stormTest/apache-storm-1.1.1/lib/servlet-api-2.5.jar:/home/luc/stormTest/apache-storm-1.1.1/lib/slf4j-api-1.7.21.jar:/home/luc/stormTest/apache-storm-1.1.1/lib/objenesis-2.1.jar:/home/luc/stormTest/apache-storm-1.1.1/lib/kryo-3.0.3.jar:/home/luc/stormTest/apache-storm-1.1.1/lib/log4j-core-2.8.2.jar:/home/luc/stormTest/apache-storm-1.1.1/lib/log4j-over-slf4j-1.6.6.jar:/home/luc/stormTest/apache-storm-1.1.1/lib/storm-core-1.1.1.jar:/home/luc/stormTest/apache-storm-1.1.1/lib/log4j-slf4j-impl-2.8.2.jar:/home/luc/stormTest/apache-storm-1.1.1/lib/minlog-1.3.0.jar:/home/luc/stormTest/apache-storm-1.1.1/lib/log4j-api-2.8.2.jar:/home/luc/stormTest/apache-storm-1.1.1/lib/clojure-1.7.0.jar:/home/luc/stormTest/apache-storm-1.1.1/lib/ring-cors-0.1.5.jar:/home/luc/stormTest/apache-storm-1.1.1/lib/asm-5.0.3.jar:/home/luc/stormTest/apache-storm-1.1.1/lib/reflectasm-1.10.1.jar:/home/luc/stormTest/apache-storm-1.1.1/lib/disruptor-3.3.2.jar:/home/luc/stormTest/apache-storm-1.1.1/lib/storm-rename-hack-1.1.1.jar:target/storm-starter-2.0.0-SNAPSHOT.jar:/home/luc/stormTest/apache-storm-1.1.1/conf:/home/luc/stormTest/apache-storm-1.1.1/bin -Dstorm.jar=target/storm-starter-2.0.0-SNAPSHOT.jar -Dstorm.dependency.jars= -Dstorm.dependency.artifacts={} org.apache.storm.starter.ExclamationTopology -local Error: Could not find or load main class org.apache.storm.starter.ExclamationTopology
我做错了什么吗?我也有点困惑是否必须先运行 nimbus 和supervisor。我尝试过使用和不使用它们,但无论如何都不起作用。一直在网上搜索但没有任何效果。不确定还可以尝试什么。
最佳答案
这通常是由于storm-client和storm-starter版本不一致造成的。尝试按照以下步骤操作以使示例正常运行。
从
http://storm.apache.org/downloads.html
下载最新版本- 在此示例中,我们将使用版本 1.1.1
- 在此示例中,我们将使用版本 1.1.1
将其提取到一个文件夹,我们将其命名为
${STORM_HOME}
cd 进入
${STORM_HOME}/examples/storm-starter
执行
mvn package -DskipTests=true
- 这应该在目标文件夹中构建storm-starter jar
${STORM_HOME}/examples/storm-starter/target/storm-starter-1.1.1.jar
- 这应该在目标文件夹中构建storm-starter jar
从
${STORM_HOME}
目录运行示例:
./bin/storm jar Examples/storm-starter/target/storm-starter-1.1.1.jar org.apache.storm.starter.ExclamationTopology
不要添加-local
标志,因为如果没有传递参数,ExclamationTopology
似乎只部署在LocalCluster
中。您可以在此处查看源代码:${STORM_HOME}/examples/storm-starter/src/jvm/org/apache/storm/starter/ExclamationTopology.java
关于java - Apache Storm - 无法找到或加载主类 org.apache.storm.starter.ExclamationTopology,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/46991792/