现场分组以防工人在 Storm 中死亡

Question

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

Answer 1

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

如果一个粗体实例失败，Storm 会将任务转移到其他 Bolt 实例。