阿帕奇Storm-喷口和螺栓不存在于StormUI
我正在本地开发一个Storm拓扑。我正在使用Storm 0.9.2孵化，并开发了一个简单的拓扑。当我使用LocalCluster（）选项部署它时，它工作得很好，但它不会显示在我的Storm UI中，它只是执行而已。
当我定期部署它时，它会在我的Storm UI中显示拓扑结构，但当我单击它时，不会看到喷口或螺栓。
我还尝试了许多Storm启动项目中的示例WordCountTopology。同样的行为也会发生。
我的问题是，为什么喷口和螺栓没有显示出来？如果您在本地部署拓扑而不使用LocalCluser（）选项，这会导致问题吗？是否有可能在我的本地框上部署拓扑，并在StormUI中看到它与所有喷口和螺栓，而不是立即执行，而是等待诸如kafka消息之类的东西？
共有1个答案
你是Storm主管吗？如果您部署了一个新的拓扑，并且Supervisor没有运行，那么该拓扑将显示在UI中，但由于它从未初始化，因此当您单击它时，它不会显示任何统计信息。
-
我在本地模式下运行Apache Storm拓扑，它工作正常，但是当我将其提交给Storm时，喷口和螺栓不会显示在StormUI中，除了拓扑。 有人建议监督员应该运行，我也尝试过，即监督员、雨云和动物园管理员运行良好。提前谢谢。有人问了类似的问题，这表明监督员应该在阿帕奇Storm上——喷口和螺栓不存在于StormUI...但这在我的情况下不起作用任何想法，请。
-
因此，如果您使用基于JUnit的单元测试，是否建议您运行一个小型模拟拓扑(？）并测试该拓扑下的（或)的隐含契约？或者，是否可以使用JUnit，但这意味着我们必须仔细模拟Bolt的生命周期（创建它、调用、嘲弄等）？在这种情况下，被测类（螺栓/喷口）有哪些一般的测试点需要考虑？ 其他开发人员在创建正确的单元测试方面做了什么？ 我注意到有一个拓扑测试API（参见：https://github.com/x
-
我在Apache Storm拓扑上运行了一个性能测试，并注意到kinesis-spout中的“failed”计数非常高（几乎占了元组的1/3）。这个数值是多少？
-
在我的拓扑中，当元组从spout转移到bolt或从bolt转移到bolt时，我看到大约1-2 ms的延迟。我使用纳秒时间戳来计算延迟，因为整个拓扑运行在单个Worker中。拓扑是在集群中运行的，集群运行在具有生产能力的硬件中。 根据我的理解，在这种情况下，元组不需要序列化/反序列化，因为所有东西都在单个JVM中。我已经将大多数喷流和螺栓的并行性提示设置为5，并且喷流仅以每秒100的速率产生事件。我