如何在Storm拓扑中处理元组？
共有1个答案
Spout和Bolt任务都是并行运行的，而不是一个接一个地运行。有关更多详细信息，请参见了解Storm拓扑的并行性
-
我正在运行一个3节点的Storm集群。我们正在提交一个包含10个工作者的拓扑结构，以下是拓扑结构的详细信息 我们每天处理800万到1000万个数据。问题是topolgy只运行了2到3天，而我们在kafka spout中看到了一些失败的元组，没有处理任何消息。当提交新的topolgy时，它工作良好，但在2到3天后，我们又看到了同样的问题。有人能给我们一个解决方案吗。下面是我的storm配置
-
问题内容： 我们是新来的风暴。我们不知道如何创建拓扑，请帮助我们应对风暴。我们尝试了“ Windows上的狂风暴雨”一文中给出的示例wordcount c = topology。但是我们无法理解如何给出输入，以及风暴用户界面中输入存在的位置以及输出存在的位置。 问题答案： 输入和输出在Storm UI中不存在。在Storm UI中，您看不到发出的元组，处理时间，集群配置和集群的运行状况。要查看输出
-
现在我想在一个污点中使用Drools，它在LocalCluster中正常工作，但是当我把它放在生产集群中时，它有错误。污点是： 我使用官方文件创建了kiesession。误差为： 也许有些东西没有初始化。但当blot执行时，我创建了一个新的kieservice。有人能帮我吗 谢啦！
-
我刚来暴风，所以温柔点：-） 什么是实现这一目标的最佳方式？
-
我正在尝试使用Eclipse在Linux中运行Storm启动示例。我收到以下错误和函数从未被调用。 错误： 我的拓扑类： 我正在虚拟机环境中工作，所以不知道这是否是由于安装了Zookeeper。有什么想法吗？
-
8台机器一直在使用。每一个都有22个核心和512 GB的RAM。但是，我们的代码运行得真的很慢。传输600万个数据需要10分钟才能完成。 60个文件中的10 MB在一秒钟内传输到HDFS。我们正在努力优化我们的代码，但很明显我们做了一些非常错误的事情。 对于蜂巢表，我们有64个桶。 在HDFS喷口；.setmaxextending(50000)； 在蜂巢喷口选项；.WithTxNsperBatch