Apache Storm Supervisor 不是 运行 Bolt

Apache Storm Supervisor not Running the Bolt

我已经在 Amazon EC2 实例上创建了一个风暴集群。我在本地环境(伪分布式环境)中测试了我的代码,它运行良好。但是当我 运行 分布式环境中的代码时,代码似乎不起作用。 在设置集群时我是否遗漏了一些技术问题

我可以声明主管节点没有 运行 固定螺栓,因为我检查了所有主管节点的 CPU 用法其中 none 超过 1%,但主(光轮)每次都 运行 达到 100%,直到代码执行完成。

我还检查了主管节点中的 Java 进程 运行ning 并且 "jps" 没有显示我的拓扑结构。

注意:该集群在 UI 运行ning over nimbus 中显示了 2 个主管。说明集群已经搭建在分布式环境中

我的问题的解决方案:

之前我是 运行 使用 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();