複数のApacheストームボルトタスク間で同時にハッシュマップを共有

Question

私は特定のタプルからハッシュマップにキーと値を書き込み、他のものに格納されているキーを使用してハッシュマップから値を読み取ります。タスクの数が1に設定されているときはうまく動作しますが、この数値を増やすとすぐに、キーは無効になるときにヌル値を返すようになります。これは、各ボルトタスクがハッシュマップの独自のインスタンスを作成していて、データが共有されていないためです。どのようにしてすべてのボルトタスクが1つのハッシュマップを共有するのですか？私は現在、それほどのような方法を準備中にハッシュマップを作成してい

：

protected Map<String, JsonObject> hashMap; 

@Override 
public void prepare(Map stormConf, TopologyContext context, OutputCollector collector) 
{ 
    _collector = collector; 
    hashMap = Collections.synchronizedMap(new ConcurrentHashMap<String, JsonObject>()); 

} 

私はまた、トポロジーレベルでのハッシュマップを定義し、変数として、私のボルトにそれを与えて試してみましたが、これは動作しませんでした。

Answer 1

タスクは、異なるワーカー（つまり異なるマシン）に配備できるため、タスク間でメモリ内のものを共有することはできません。

「仕事の独立した作業単位」としての仕事は、自分の入力だけに依存しなければなりません。