apache storm supervisor未运行螺栓

gupuwyp2 于 2021-06-21 发布在 Storm

关注(0)|答案(1)|浏览(388)

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

Java amazon-ec2 apache-storm real-time-data

来源：https://stackoverflow.com/questions/28667548/apache-storm-supervisor-not-running-the-bolt

1条答案

按热度按时间

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();

赞(0）回复(0）举报 2021-06-21

我来回答

apache storm supervisor未运行螺栓

1条答案

相关问题

热门标签

最新问答