twitter storm worker只能获得部分拓扑吗？
假设您具有以下拓扑
喷口
spout (sends tuple to )bolt1
bolt1 (sends tuple to) bolt2
spout,parallel hint=1
bolt1, parallel hint=2
bolt2,parallel hint=3
>
我对以下（可能的）工人分布的看法是正确的吗：
Worker1
spout1
bolt 2
Worker2
bolt 1
bolt 2
Worker3
bolt1
bolt 2
共有1个答案
您需要区分不同的任务是如何在您的员工之间分配的，以及您的喷管和螺栓之间的分组。分组决定如何在拓扑中路由元组。例如，如果在spout和bolt1之间使用all分组，bolt1中的每个任务都将接收spout发送的每个元组。Storm有很多不同的分组，我建议您仔细阅读Storm概念页面，这应该可以回答您的问题：https://github.com/nathanmarz/Storm/wiki/concepts。
-
我是阿帕奇Storm的新手。我已经在intellij中用java创建了一个storm项目，它成功地创建了一个本地集群，并将拓扑提交给它，然后在本地运行。我想在亚马逊EC2上运行这个Storm项目。我跟踪了https://github.com/nathanmarz/storm-deploy/wiki链接。跟随链接成功发射了2个主管，1个动物园管理员和1个灵光。现在我想在服务器上运行我的拓扑。这是我在
-
我对Apache Storm的性能有一个问题，主要是从喷口出来的。 我有一个从kestrel队列发出项目的拓扑。我获取大约2000个项目，每次在喷注中调用时，我都会发出一个。 我正在使用1个spout任务和1个spout执行器运行。我已将设置为10。 为什么每次调用之间有这么大的时间间隔？outputCollector在发出一个新元组之前是否正在等待听到每个元组的反馈？ 我正在运行Java8和st
-
问题内容： 好的，因此在根据输入数据进行拓扑排序时，通常存在多个正确的解决方案，可以根据这些正确的解决方案对图进行“处理”，以便所有依赖项都位于“依赖”它们的节点之前。但是，我正在寻找稍微不同的答案： 假设以下数据： 和（必须先于并且必须先于）。 只有这两个限制，我们有多种候选方案：（ ，， 等）。但是，我正在寻找一种将这些节点“分组”的方法，以便在处理完一组后，下一组中的所有条目都将处理其依赖项
-
我正在运行一个3节点的Storm集群。我们正在提交一个包含10个工作者的拓扑结构，以下是拓扑结构的详细信息 我们每天处理800万到1000万个数据。问题是topolgy只运行了2到3天，而我们在kafka spout中看到了一些失败的元组，没有处理任何消息。当提交新的topolgy时，它工作良好，但在2到3天后，我们又看到了同样的问题。有人能给我们一个解决方案吗。下面是我的storm配置
-
为了表明计算机科学家可以把任何东西变成一个图问题，让我们考虑做一批煎饼的问题。 菜谱真的很简单：1个鸡蛋，1杯煎饼粉，1汤匙油 和 3/4 杯牛奶。 要制作煎饼，你必须加热炉子，将所有的成分混合在一起，勺子搅拌。 当开始冒泡，你把它们翻过来，直到他们底部变金黄色。 在你吃煎饼之前，你会想要加热一些糖浆。 Figure 27将该过程示为图。 Figure 27 制作煎饼的困难是知道先做什么。从 Fi
-
一、拓扑排序介绍 拓扑排序(Topological Order)是指，将一个有向无环图(Directed Acyclic Graph简称DAG)进行排序进而得到一个有序的线性序列。 这样说，可能理解起来比较抽象。下面通过简单的例子进行说明！ 例如，一个项目包括A、B、C、D四个子部分来完成，并且A依赖于B和D，C依赖于D。现在要制定一个计划，写出A、B、C、D的执行顺序。这时，就可以利用到拓扑排序