apache storm - Set and get tuple fail cause -
is possible communicate cause of tuple failure bolt failed spout emitted it? want have different logic in spout fail method of fail causes.
since public void fail(object id)
takes id need manage yourself.
inside bolt, persist tuple id along fail cause somewhere (distributed key/value store perhaps?).
Comments
Post a Comment