当尝试运行时,开始使用Storm示例代码(https://github.com/storm-book/examples-ch03-topologies):
> storm jar target/Topologies-0.0.1-SNAPSHOT.jar countword.TopologyMain src/main/resources/words.txt
我得到了以下例外:
Exception in thread "main" java.lang.NoSuchMethodError: backtype.storm.topology.TopologyBuilder.setBolt(Ljava/lang/String;Lbacktype/storm/topology/IRichBolt;Ljava/lang/Integer;)Lbacktype/storm/topology/BoltDeclarer;
at countword.TopologyMain.main(TopologyMain.java:23)
我已经检查了方法签名,一切似乎都是正确的。对这一问题的任何见解都将不胜感激。谢谢!
发布于 2014-05-08 03:59:44
从您的pom文件中可以看到您使用的是strom版本的0.7.1
<dependency>
<groupId>storm</groupId>
<artifactId>storm</artifactId>
<version>0.7.1</version>
具有方法签名的
public BoltDeclarer setBolt(String id, IBasicBolt bolt, Integer parallelism_hint);
将该版本更改为0.9.0.1
,您将能够运行该版本
<dependency>
<groupId>storm</groupId>
<artifactId>storm</artifactId>
<version>0.9.0.1</version>
</dependency>
发布于 2014-10-14 19:11:59
在使用ORMERV0.9.0.1更新pom之后,您将需要到一个mvn clean install
,然后一个mvn package
来更新发送到集群的jar。
https://stackoverflow.com/questions/23532063
复制相似问题