【发布时间】:2018-05-26 15:16:23
【问题描述】:
我有一个螺栓可以从 Storm 的 spout 中以 filedGrouping 方式处理数据。有一天,一台机器停机,螺栓自动转移到另一台机器上。在filedGrouping 方式中,来自spout 的一些元组不会被任何bolt 处理。我该怎么办?
【问题讨论】:
标签: apache-storm
我有一个螺栓可以从 Storm 的 spout 中以 filedGrouping 方式处理数据。有一天,一台机器停机,螺栓自动转移到另一台机器上。在filedGrouping 方式中,来自spout 的一些元组不会被任何bolt 处理。我该怎么办?
【问题讨论】:
标签: apache-storm
如果你使用acking,丢失的元组应该由spout重试。
【讨论】: