如果检查确定的螺栓是否正在处理，螺栓在队列中是否有要插入的元组之类的内容，就可以满足这个要求。在简历中，我想知道的是，不管怎样，拓扑结构是否已经完成了工作。我知道这听起来很矛盾，因为拓扑不应该完成工作，但我用它来做测试，一开始我没有不间断的数据流，而是有限的数据量。
ffscu2ro1#
你可以检查它从风暴用户界面，我认为这是最简单的方法。
juud5qan2#
要检查正在运行的拓扑及其状态，可以运行：
{dir/to/storm}/bin/storm list
您还可以导航到正在运行的storm ui并从中检查拓扑/日志。如果您想检查是否在元组上执行了工作，那么您可以添加自己的日志记录。我添加了一些逻辑来打印出每秒处理多少元组，我发现这些元组很有用。
2条答案
按热度按时间ffscu2ro1#
你可以检查它从风暴用户界面，我认为这是最简单的方法。
juud5qan2#
要检查正在运行的拓扑及其状态，可以运行：
您还可以导航到正在运行的storm ui并从中检查拓扑/日志。
如果您想检查是否在元组上执行了工作，那么您可以添加自己的日志记录。我添加了一些逻辑来打印出每秒处理多少元组，我发现这些元组很有用。