Apache Storm元组超时问题

Question

我试图理解在元组处理超时的情况下拓扑的状态（不是在三叉戟模式下），让我们假设在某个bolt中处理元组的过程中达到了超时阈值。在这种情况下，spout再次发出初始元组（我所理解的消息id相同）。现在让我们假设Bolt完成对元组的处理，并发出和acks该元组。在这种情况下：

1. 即使spout发出了一个新的初始元组，失败的元组仍会继续由拓扑处理吗？
2. 如果是这样的话，这个用户的元组DAG会是什么样子（因为有一个新的DAG是用相同的初始元组id创建的），那么之前的原始DAG会发生什么呢？
3. 当攻击者接收到ack并发射前一个DAG的锚点ID时，会发生什么？

Answer 1

1：是的，失败的元组继续。这样做的原因是，试图阻止失败的元组继续运行的代价太大，因为喷口需要告诉所有螺栓关于失败的信息。

2：我想这里有一个小小的误会。当spout发出元组时，消息id不是Storm用来在内部跟踪该元组dag/tree的。相反，spout执行器生成一个随机id（称为rootid)，并在本地存储rootid->messageid的映射。消息id不会离开spout执行器，也不会传播到bolt。

当spout执行器继续发送元组时，它包括rootid。rootid是acker和bolts用来标识元组树的东西。

为了清楚起见，我将上面的内容简化了一些，为了处理向多个螺栓发射的喷口，还涉及另一组随机ID(anchorid)。从概念上讲，你可以认为

spout -> bolt1
      -> bolt2

就像处理拓扑一样

spout -> splitterBolt -> bolt1
                      -> bolt2

3：假设您的元组超时了。spout执行程序被告知rootid已失败。发生这种情况时，spout执行程序调用spout.fail(msgId)，然后删除rootid->messageid映射中的映射。