提交到远程集群时java Strom ClassNotFoundException
我有一个非常简单的拓扑:
builder.setSpout("StreamSpout", new StreamSpout(), 1);
builder.setBolt("Bolt", new TestBolt(), 1).shuffleGrouping("StreamSpout");
溪流喷口:
public void open(Map conf, TopologyContext context, SpoutOutputCollector collector) {
this.outputCollector = collector;
this.config = conf;
this.context = context;
}
public void nextTuple() {
this.outputCollector.emit(new Values("test"));
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
public void declareOutputFields(OutputFieldsDeclarer declarer) {
declarer.declare(new Fields("word"));
}
测试螺栓:
public void execute(Tuple input, BasicOutputCollector collector) {
String word = input.getStringByField("word");
Logger.getLogger(this.getClass()).info(word);
}
我使用以下代码提交:
conf.put(Config.NIMBUS_HOST, "W.X.Y.Z"); // Cluster's IP
conf.put(Config.NIMBUS_THRIFT_PORT,6627);
conf.put(Config.STORM_ZOOKEEPER_PORT,2181);
System.setProperty("storm.jar", "/home/.../{FileName}-SNAPSHOT.jar"); // Generated JAR file path
StormSubmitter submitter = new StormSubmitter();
submitter.submitTopology("de-linkS", conf, builder.createTopology());
但是,每当我尝试将拓扑提交到集群时,就会从工作日志文件中得到以下错误:
2015-04-06 21:36:03 b.s.d.worker [ERROR] Error on initialization of server mk-worker
java.lang.RuntimeException: java.lang.ClassNotFoundException: upa.pfe.storm.spouts.StreamSpout
at backtype.storm.utils.Utils.deserialize(Utils.java:95) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
at backtype.storm.utils.Utils.getSetComponentObject(Utils.java:235) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
at backtype.storm.daemon.task$get_task_object.invoke(task.clj:73) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
...
但是,当将拓扑提交到本地集群时,一切都可以完美地工作
你知道我可能做错了什么吗
谢谢
# 1 楼答案
所以我想出来了
问题似乎出在项目的pom中。xml文件。pom文件缺少所需的插件:
我能够使用以下pom文件作为我的基础来打包和部署我的项目:https://github.com/apache/storm/blob/master/examples/storm-starter/pom.xml
这是一种进入truble的愚蠢方式,但我希望这条线索能对其他人有所帮助和启发
多谢各位