案例工作者在风暴中死亡的字段分组

Question

我有一个用例，我正在使用本地缓存来维护某些ID的计数器。我在拓扑类中做了fieldsGrouping("spout", new Fields("id"))。 假设id1总是在processingBolt上worker1和id2处理在processingBoltworker2总是得到处理。如果worker2死亡，将id2开始处理worker1？

Answer 1

是的。 Storm在内部使用抽象的任务。如果使用fieldsGrouping，每个ID都映射到一个任务，任务由螺栓实例执行。

如果一个黑体实例失败，Storm会将任务移动到其他螺栓实例。