2016-12-06 74 views

回答

1

为什么你不想使用停止按钮?似乎罚款给我...

另一种方法是睡了一点点,然后关机使用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这样的命令,它基本上是一个大的停止按钮。 :)

+0

我不会停止调用从螺栓清理方法。 – Igorzovisk

+0

这是非常现实的,因为清理可能不会在生产中调用。 –

+0

但我正在测试的东西,所以现在我想要清理被调用。 – Igorzovisk