Apache Storm Supervisor未运行螺栓

问题描述：

我已经在Amazon EC2实例上创建了一个风暴集群。我在本地环境（伪分布式环境）中测试了我的代码，并且它工作正常。但是，当我在分布式环境中运行代码时，代码似乎不起作用。 在设置集群的同时，有没有什么技术我在这里失踪。Apache Storm Supervisor未运行螺栓

我可以声明主管节点没有运行螺栓，因为我检查了所有主管节点的CPU使用率的，并且它们都没有超过1％，但主（nimbus）运行在每次100％，直到代码执行完成。

我还检查了在supervisor节点中运行的Java进程，并且“jps”未显示我的拓扑。

注意：集群在通过nimbus运行的用户界面中显示2个主管。这表明该集群是在分布式环境中安装的。

有什么日志说...可能是有用的，如果在这里提供他们 – user2720864 2015-02-23 11:11:01

我解决了我的问题，并在这里添加我的解决方案。 – 2015-02-25 05:05:29

你应该添加你的解决方案作为答案，并接受你自己的答案;） – 2015-10-19 15:21:52

答

解决我的问题：

以前我是运行使用的LocalCluster代替StormSubmitter

使用此：代替

StormSubmitter.submitTopologyWithProgressBar(args[0], conf, builder.createTopology());

：

LocalCluster cluster = new LocalCluster(); 
cluster.submitTopology("test", conf, builder.createTopology()); 
Utils.sleep(10000); 
cluster.killTopology("test"); 
cluster.shutdown();

Apache Storm Supervisor未运行螺栓

相关推荐