我已经在amazonec2示例上创建了一个storm集群。我在本地环境(伪分布式环境)中测试了我的代码,效果很好。但是当我在分布式环境中运行代码时,代码似乎不起作用。在设置集群时,这里是否缺少一些技术性的东西。
我可以声明,主管节点没有运行螺栓,因为我检查了所有主管节点的cpu使用率,没有一个超过1%,但是主节点(nimbus)每次都在100%运行,直到代码执行完成。
我还检查了在supervisor节点中运行的java进程,“jps”没有显示我的拓扑。
注意:集群显示ui中运行nimbus的2个管理器。说明集群是在分布式环境下建立的。
1条答案
按热度按时间rslzwgfq1#
我的问题解决方案:
以前我是用
LocalCluster
而不是StormSubmitter
使用此选项:而不是: