运行 Storm Topology 时找不到主类

Question

我正在使用storm jar 类向“nimbus”提交拓扑。它在本地工作正常，但在远程集群上它说它无法加载主类。以下是错误

stderr: SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/usr/local/storm-0.9.0.1/lib/logback-classic-1.0.6.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/tmp/storm-starter.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
Error: Could not find or load main class ExclamationTopology

我在 CLI 上运行以下命令：

usr/local/storm/bin/storm jar /tmp/storm-starter.jar ExclamationTopology

Answer 1

对我来说，这是一个类路径问题。一旦我遍历到 jar 所在的目录并运行命令，一切正常。

从 Storm 主文件夹运行

./bin/storm jar examples/storm-starter/storm-starter-topologies-0.9.3.jar storm.starter.WordCountTopology TOne

Failed with error: Error: Could not find or load main class storm.starter.WordCountTopology

Running from directory examples/storm-starter

/root/storm/apache-storm-0.10.0/bin/storm jar storm-starter-topologies-0.10.0.jar storm.starter.WordCountTopology TOne

工作正常。

Answer 2

storm-starter.jar 的打包可能存在问题：此 jar 不应包含 sl4j 实现。为了打包storm-starter示例（https://github.com/nathanmarz/storm-starter），从根文件夹（存在m2-pom.xml）运行以下命令：

mvn -f m2-pom.xml package

这应该会在 target/ 文件夹中生成这个文件：

storm-starter-0.0.1-SNAPSHOT-jar-with-dependencies.jar

然后，为了将其部署到集群（实际上，通过 Nimbus），您需要告诉storm jar 命令包含提供拓扑定义的main() 的类的完全限定名称，例如这个（确保你使用带有“-with-dependencies”的那个）：

usr/local/storm/bin/storm jar storm-starter-0.0.1-SNAPSHOT-jar-with-dependencies.jar storm.starter.ExclamationTopology

Answer 3

我遇到了类似的暴风雨错误，并且通过添加 pom.xml 中提供的内容得到了修复。当您添加提供时，maven 不会将这些库捆绑到 jar 中。

Answer 4

尝试像这样运行：

java -jar /tmp/storm-starter.jar ExclamationTopology

在这里得到答案：Run Jar in Console