我在风暴群上运行了风暴拓扑。后来拓扑结构被破坏了。但它并没有从拓扑列表中删除。因此,我不能用相同的名称重新运行拓扑。难道没有办法从列表中删除被杀死的拓扑吗?
cwdobuhd1#
从storm ui或命令行运行kill命令时。storm将首先在拓扑的消息超时期间停用拓扑的喷口,以允许当前正在处理的所有消息完成处理。风暴将关闭工人和清理他们的状态。所以,也许你的拓扑还有需要处理的消息,所以拓扑到现在还没有消亡。
vfh0ocws2#
在终止拓扑时,通常会设置一个超时时间,以等待处理当前发出的元组。我想默认值是30秒。之后,应该从列表中删除拓扑。如果不想等待,只需指定0秒的超时,拓扑将立即删除。
uplii1fm3#
另一种杀死拓扑的方法是从命令行运行storm kill。当一个拓扑挂在“被杀死”状态并在列表中显示数小时时,这对我来说是有效的。
storm kill yourToplogyName -w 5
3条答案
按热度按时间cwdobuhd1#
从storm ui或命令行运行kill命令时。storm将首先在拓扑的消息超时期间停用拓扑的喷口,以允许当前正在处理的所有消息完成处理。风暴将关闭工人和清理他们的状态。
所以,也许你的拓扑还有需要处理的消息,所以拓扑到现在还没有消亡。
vfh0ocws2#
在终止拓扑时,通常会设置一个超时时间,以等待处理当前发出的元组。我想默认值是30秒。之后,应该从列表中删除拓扑。如果不想等待,只需指定0秒的超时,拓扑将立即删除。
uplii1fm3#
另一种杀死拓扑的方法是从命令行运行storm kill。当一个拓扑挂在“被杀死”状态并在列表中显示数小时时,这对我来说是有效的。