案例工作者在風暴中死亡的字段分組

Question

我有一個用例，我正在使用本地緩存來維護某些ID的計數器。我在拓撲類中做了fieldsGrouping("spout", new Fields("id"))。 假設id1總是在processingBolt上worker1和id2處理在processingBoltworker2總是得到處理。如果worker2死亡，將id2開始處理worker1？

Answer 1

是的。 Storm在內部使用抽象的任務。如果使用fieldsGrouping，每個ID都映射到一個任務，任務由螺栓實例執行。

如果一個黑體實例失敗，Storm會將任務移動到其他螺栓實例。