apache storm supervisor未运行螺栓

gupuwyp2  于 2021-06-21  发布在  Storm
关注(0)|答案(1)|浏览(386)

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

rslzwgfq

rslzwgfq1#

我的问题解决方案:
以前我是用 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();

相关问题