storm acker 2017-06-02 PubSub Acker对于Spout产生的每一个tuple, storm都会进行跟踪,利用RotatingMap存放内存,但有保护措施,不会打爆 当Spout触发fail动作时,storm不会自动重发失败的tuple,只是向Spout发送fail消息,触发Spout.fail回调,真正的重发需要在Spout.fail里实现 tuple tree,中间任意一个edge fail,会理解触发Spout的fail,但后面的Bolt的执行不受影响。做无用功? Spout Executor Bolt Executor Newer facebook Mystery Machine Older monkey patch golang