0
我的项目使用Maven。
要执行拓扑,我只需在Netbeans中运行拓扑文件。问题是我不知道如何关闭它。
我不想停止执行程序(停止按钮)。我想告诉拓扑它需要关闭。
我该怎么做?netbeans - 如何在Netbeans中关闭Apache Storm的拓扑结构?
我的项目使用Maven。
要执行拓扑,我只需在Netbeans中运行拓扑文件。问题是我不知道如何关闭它。
我不想停止执行程序(停止按钮)。我想告诉拓扑它需要关闭。
我该怎么做?netbeans - 如何在Netbeans中关闭Apache Storm的拓扑结构?
为什么你不想使用停止按钮?似乎罚款给我...
另一种方法是睡了一点点,然后关机使用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();
如果在集群上正在运行你使用风暴CLI来运行一个像storm kill topology-name
这样的命令,它基本上是一个大的停止按钮。 :)
我不会停止调用从螺栓清理方法。 – Igorzovisk
这是非常现实的,因为清理可能不会在生产中调用。 –
但我正在测试的东西,所以现在我想要清理被调用。 – Igorzovisk