gpt4 book ai didi

java - ack 方法仅适用于第一个 bolt ,不适用于其他 bolt

转载 作者:太空宇宙 更新时间:2023-11-04 14:29:05 29 4
gpt4 key购买 nike

我有一个拓扑,例如由 1 个喷嘴和 4 个 bolt 组成

spout 1 -> bolt A -> bolt B -> bolt C -> bolt D

如果 bolt A 中的某些条件不满足,我们现在称之为:

collector.ack(tuple);

它将调用Spout中的ack方法。

如果某些条件不满足,则在 Bolt B 中我们称之为相同的:

collector.ack(tuple);

但它没有调用Spout中的ack方法。相反,在一段时间后它会调用 fail 方法?

不知道为什么?对于第一级 bolt ack有效,但不适用于其他 bolt 。

最佳答案

你的问题不是很清楚,但我猜你基本上没有确认每个执行的 bolt 。规则很简单 - 每个执行的 Bolt 都必须确认输入元组。否则,spout 不会被确认并发生超时(因此会调用失败方法)。

关于java - ack 方法仅适用于第一个 bolt ,不适用于其他 bolt ,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/26355294/

29 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com