ストームでワーカーが死亡した場合のフィールドグループ

Question

特定のIDのカウンタを維持するためにローカルキャッシュを使用しているユースケースがあります。トポロジクラスでfieldsGrouping("spout", new Fields("id"))を実行しました。 id1が常にprocessingBoltでworker1で処理され、id2が常にのprocessingBoltで処理されていたとします。 worker2が死亡した場合、id2はworker1で処理され始めますか？

Answer 1

はい。 Stormは内部的にタスクの抽象化を使用していました。 fieldsGroupingを使用すると、各IDはタスクにマッピングされ、タスクはボルトインスタンスによって実行されます。

大胆なインスタンスが1つ失敗した場合、Stormはタスクを他のボルトインスタンスに移動します。