我正在使用Java类向Storm集群提交拓扑,还计划使用Java类终止拓扑。但根据storm documentation,以下命令用于终止拓扑,并且没有Java方法(这有合理的原因)。
storm kill {stormname}
那么从Java类调用一个shell脚本来取消拓扑是否合适呢?还有什么其他方法可以取消拓扑呢?
另外,如何获取 Storm 集群中运行拓扑的状态?
我正在使用Java类向Storm集群提交拓扑,还计划使用Java类终止拓扑。但根据storm documentation,以下命令用于终止拓扑,并且没有Java方法(这有合理的原因)。
storm kill {stormname}
那么从Java类调用一个shell脚本来取消拓扑是否合适呢?还有什么其他方法可以取消拓扑呢?
另外,如何获取 Storm 集群中运行拓扑的状态?
2条答案
按热度按时间pxy2qtax1#
要删除拓扑,可以尝试以下操作
获取拓扑运行状态
t1qtbnec2#
从Storm 1.0.0开始,从喷口或螺栓中删除拓扑需要通过
nimbus.seeds
指定nimbus主机位置(或者,如果不是通过代码执行此操作,则需要在storm.yaml
文件中指定nimbus.seeds):请注意,这样做也会结束您的程序。