BaseRichSpout - Apache Stormのfail（）メソッドの失敗の原因を見つける方法？

Question

次のように私はトポロジを持っている：

スパウトは Bolt1はタプルを受け取る場所 Bolt2及びその他のストリーム "bolt1stream"が加入されたストリーム "mystream"があり

Spout --> Bolt 1 --> Bolt2 --> Bolt3 

。タプルの失敗（私の場合はBolt2）の場合

は、私がこのためBolt1からではなく、再びBolt2から

を、それを再生したいと思い、私はBolt2でタプルを失敗します。この失敗メッセージがspoutに達すると、失敗したポイントに基づいてmystream/bolt1streamに送信します。したがって、障害ポイントからの処理が開始されます。

ただし、BaseRichSpoutのfail（）には、TupleではなくObjectパラメータがあります。私はタプルと同じように、sourceComponentをどのように知っていますか？または、それが失敗した場所からタプルを再生する最善の方法は何ですか。

ありがとうございます。

Answer 1

ストリームごとに、ストリームを識別するために別のクラスを使用します。別の方法としては、同じクラスを使用し、ストリームを識別するクラス内に整数または列挙型を持たせる方法があります。

@Override 
public void fail(Object msgId) { 
    if (msgId instanceof MyTupleClass) { 
    // Default stream 
    MyTupleClass oneTuple = (MyTupleClass) msgId; 
    //---tuple replay logic. Re-emitting the failed tuples  
    ReEmitTheDefaultStreamTuple(oneTuple); 
} 
else { 
    //it's the other stream 
    //For this stream you could perhaps use MySecondTupleClass 
}