storm acker

Acker

对于Spout产生的每一个tuple, storm都会进行跟踪,利用RotatingMap存放内存,但有保护措施,不会打爆

当Spout触发fail动作时,storm不会自动重发失败的tuple,只是向Spout发送fail消息,触发Spout.fail回调,真正的重发需要在Spout.fail里实现

tuple tree,中间任意一个edge fail,会理解触发Spout的fail,但后面的Bolt的执行不受影响。做无用功?

backtype.storm.daemon.acker

Spout Executor

spout executor

Bolt Executor

bolt executor

Share Comments