我的项目使用maven。为了执行拓扑，我只需在netbeans中运行拓扑文件。问题是我不知道怎么关掉它。我根本不想停止程序的执行（停止按钮）。我想告诉topology它需要关闭。我该怎么做？
yzuktlbb1#
你为什么不想用停止按钮呢？我觉得很好。。。另一种方法是先休眠一段时间，然后使用storm的api关闭集群：
LocalCluster cluster = new LocalCluster(); LOG.info("Submitting local topology, will be shutdown in 60s"); cluster.submitTopology("CountingTopology", conf, builder.createTopology()); Thread.sleep(60000); cluster.shutdown();
如果它在集群上运行，您可以使用storms cli运行如下命令 storm kill topology-name 基本上是一个大的停止按钮。：）
storm kill topology-name
1条答案
按热度按时间yzuktlbb1#
你为什么不想用停止按钮呢？我觉得很好。。。
另一种方法是先休眠一段时间，然后使用storm的api关闭集群：
如果它在集群上运行，您可以使用storms cli运行如下命令
storm kill topology-name基本上是一个大的停止按钮。：）